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.
Code Block | ||||
---|---|---|---|---|
| ||||
@Internal public class MetadataUpdateEvent implements SourceEvent { private final Map<KafkaClusterIdentifier, Set<String>> currentClusterTopics; ... } |
...