public final class ZKTopicMetadataCollectorContext extends Object implements AutoCloseable
Constructor and Description |
---|
ZKTopicMetadataCollectorContext(ZKTopicMetadataCollectorConfig config,
Map<String,TopicInfo> initialTopicsWithInfo,
MetadataCollectorEventQueue eventQueue,
org.apache.kafka.common.metrics.Metrics metrics,
kafka.zk.KafkaZkClient zkClient,
kafka.server.KafkaConfig originalConfig,
int epoch,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
boolean |
cacheInitialized() |
CatalogMetrics |
catalogMetrics() |
void |
close() |
ZKTopicMetadataCollectorConfig |
config() |
int |
epoch() |
io.confluent.telemetry.api.events.EventEmitter |
eventEmitter() |
MetadataCollectorEventQueue |
eventQueue() |
Set<String> |
initialTopics() |
long |
lastSnapshotNs() |
LocalStore |
localStore() |
kafka.server.KafkaConfig |
originalConfig() |
TopicInfo |
removeTopicFromInitialSnapshot(String topicName) |
void |
setLastSnapshotNs(long snapshotNs) |
long |
startNs() |
kafka.utils.Throttler |
throttler() |
TopicInfo |
topicInfo(String topicName) |
kafka.zk.KafkaZkClient |
zkClient() |
public ZKTopicMetadataCollectorContext(ZKTopicMetadataCollectorConfig config, Map<String,TopicInfo> initialTopicsWithInfo, MetadataCollectorEventQueue eventQueue, org.apache.kafka.common.metrics.Metrics metrics, kafka.zk.KafkaZkClient zkClient, kafka.server.KafkaConfig originalConfig, int epoch, org.apache.kafka.common.utils.Time time)
public kafka.zk.KafkaZkClient zkClient()
public kafka.utils.Throttler throttler()
public MetadataCollectorEventQueue eventQueue()
public LocalStore localStore()
public io.confluent.telemetry.api.events.EventEmitter eventEmitter()
public CatalogMetrics catalogMetrics()
public kafka.server.KafkaConfig originalConfig()
public int epoch()
public long startNs()
public boolean cacheInitialized()
public ZKTopicMetadataCollectorConfig config()
public void setLastSnapshotNs(long snapshotNs)
public long lastSnapshotNs()
public void close()
close
in interface AutoCloseable