THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
This is a metadata update event containing the current metadata, sent from enumerator to reader. The metadata does not include stream information since it is not required by the reader, which does not directly interact with streams or the KafkaMetadataService.
There is also a "GetMetadataUpdateEvent" so that readers can request for metadata before starting. This is essential to filter expired metadata at startup.
| Code Block | ||||
|---|---|---|---|---|
| ||||
@Internal
public class MetadataUpdateEvent implements SourceEvent {
private final Map<KafkaClusterIdentifier, Set<String>> currentClusterTopics;
...
} |
...