public final class ZKMetadataCollectorContext extends Object implements AutoCloseable
Constructor and Description |
---|
ZKMetadataCollectorContext(ZKMetadataCollectorConfig config,
Map<String,TopicInfo> initialTopicsWithInfo,
Map<String,ClusterLinkInfo> initialClusterLinksWithInfo,
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() |
ClusterLinkInfo |
clusterLinkInfo(String clusterLink) |
ZKMetadataCollectorConfig |
config() |
int |
epoch() |
io.confluent.telemetry.api.events.EventEmitter |
eventEmitter() |
MetadataCollectorEventQueue |
eventQueue() |
Set<ClusterLinkInfo> |
initialClusterLinks() |
Set<String> |
initialTopics() |
long |
lastSnapshotNs() |
LocalStore |
localStore() |
kafka.server.KafkaConfig |
originalConfig() |
ClusterLinkInfo |
removeClusterLinkFromInitialSnapshot(String clusterLink) |
TopicInfo |
removeTopicFromInitialSnapshot(String topicName) |
void |
setLastSnapshotNs(long snapshotNs) |
long |
startNs() |
kafka.utils.Throttler |
throttler() |
TopicInfo |
topicInfo(String topicName) |
kafka.zk.KafkaZkClient |
zkClient() |
public ZKMetadataCollectorContext(ZKMetadataCollectorConfig config, Map<String,TopicInfo> initialTopicsWithInfo, Map<String,ClusterLinkInfo> initialClusterLinksWithInfo, 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 ClusterLinkInfo removeClusterLinkFromInitialSnapshot(String clusterLink)
public ClusterLinkInfo clusterLinkInfo(String clusterLink)
public Set<ClusterLinkInfo> initialClusterLinks()
public boolean cacheInitialized()
public ZKMetadataCollectorConfig config()
public void setLastSnapshotNs(long snapshotNs)
public long lastSnapshotNs()
public void close()
close
in interface AutoCloseable