Interface | Description |
---|---|
LocalStore |
A Local Store that keeps information of all logical clusters, topics and topic's
MetadataEvent . |
MetadataEventProvider<T> |
A MetadataEvent Provider for retrieving all topics and cluster links in a logical cluster.
|
Class | Description |
---|---|
BrokerConfigChangeListener | |
CatalogMetrics | |
CatalogMetrics.LongGauge | |
CatalogTopicConfigUtils | |
InMemoryLocalStore | |
KRaftMetadataCollector |
A KRaft metadata collector which collects and emits metadata snapshots and change deltas.
|
KRaftMetadataEventProvider | |
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.
|
ZkMetadataEventProvider |