public class ZKMetadataCollector extends Object
Constructor and Description |
---|
ZKMetadataCollector(kafka.server.KafkaConfig config,
kafka.zk.KafkaZkClient zkClient,
org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
Optional<ZKMetadataCollectorContext> |
collectorContext()
Get the ZKMetadataCollectorContext.
|
void |
disable()
Disable collector.
|
void |
enable(Map<String,TopicInfo> topicsWithInfo,
Map<String,ClusterLinkInfo> clusterLinksWithInfo,
int epoch)
Enable collector to start collecting metadata and sending snapshots.
|
boolean |
isActive()
An active collector means it is emitting snapshots and change deltas.
|
void |
onBrokerDefaultConfigChange(kafka.server.KafkaConfig oldConfig,
kafka.server.KafkaConfig newConfig) |
void |
onClusterLinkConfigChange(String clusterLink,
kafka.server.link.ClusterLinkConfig newConfig)
Listens to cluster link config changes.
|
void |
onClusterLinkCreate(ClusterLinkInfo newClusterLink)
Listens to cluster link creation.
|
void |
onClusterLinkDelete(String deletedClusterLink)
Listens to cluster link deletion.
|
void |
onMirrorTopicStateChange(String topic,
String mirrorTopicState)
Listens to mirror topic state change.
|
void |
onTopicConfigChange(String topic,
org.apache.kafka.storage.internals.log.LogConfig newConfig,
Properties updateProperties)
Listens to topic config changes.
|
void |
onTopicCreate(Map<String,TopicInfo> newTopicWithInfo)
Listens to topic creation.
|
void |
onTopicDelete(Set<String> deleteTopics)
Listens to topic deletion.
|
void |
onTopicPartitionChange(String topic,
int newPartition)
Listens to topic partition changes.
|
void |
setCollectorContext(Optional<ZKMetadataCollectorContext> contextOptional)
Set the ZKMetadataCollectorContext.
|
void |
shutdown()
Shutdown the collector.
|
public ZKMetadataCollector(kafka.server.KafkaConfig config, kafka.zk.KafkaZkClient zkClient, org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time)
public void disable()
public void enable(Map<String,TopicInfo> topicsWithInfo, Map<String,ClusterLinkInfo> clusterLinksWithInfo, int epoch)
public void shutdown()
public boolean isActive()
public Optional<ZKMetadataCollectorContext> collectorContext()
public void setCollectorContext(Optional<ZKMetadataCollectorContext> contextOptional)
public void onClusterLinkCreate(ClusterLinkInfo newClusterLink)
public void onClusterLinkConfigChange(String clusterLink, kafka.server.link.ClusterLinkConfig newConfig)
public void onClusterLinkDelete(String deletedClusterLink)
deletedClusterLink
- public void onMirrorTopicStateChange(String topic, String mirrorTopicState)
public void onTopicCreate(Map<String,TopicInfo> newTopicWithInfo)
public void onTopicDelete(Set<String> deleteTopics)
public void onTopicPartitionChange(String topic, int newPartition)
public void onTopicConfigChange(String topic, org.apache.kafka.storage.internals.log.LogConfig newConfig, Properties updateProperties)
public void onBrokerDefaultConfigChange(kafka.server.KafkaConfig oldConfig, kafka.server.KafkaConfig newConfig)