Interface | Description |
---|---|
LocalStore |
A Local Store that keeps information of all logical clusters, topics and topic's
MetadataEvent . |
Class | Description |
---|---|
BrokerConfigChangeListener | |
CatalogMetrics | |
CatalogMetrics.LongGauge | |
CatalogTopicConfig | |
InMemoryLocalStore | |
KRaftTopicMetadataCollector |
A KRaft topic metadata collector which collects and emits topic metadata snapshots and change deltas.
|
MetadataCollectorEventQueue |
Wrapper for the existing
KafkaEventQueue with some custom method for ZKTopicMetadataCollector. |
MetadataEventUtils |
Utility class to build Protobuf Object and CloudEvent for topic metadata change
|
TopicInfo | |
ZKTopicMetadataCollector |
A ZK topic metadata collector which collects and emits topic metadata snapshots and change deltas.
|
ZKTopicMetadataCollectorConfig | |
ZKTopicMetadataCollectorContext |
A context for ZKTopicMetadataCollector.
|