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 | |
KRaftMetadataCollector |
A KRaft metadata collector which collects and emits metadata snapshots and change deltas.
|
MetadataCollectorEventQueue |
Wrapper for the existing
KafkaEventQueue with some custom method for ZKMetadataCollector. |
MetadataEventUtils |
Utility class to build Protobuf Object and CloudEvent for topic metadata change
|
ZKMetadataCollector |
A ZK topic metadata collector which collects and emits topic metadata snapshots and change deltas.
|
ZKMetadataCollectorConfig | |
ZKMetadataCollectorContext |
A context for ZKMetadataCollector.
|