public class ZKTopicMetadataCollector extends Object
Constructor and Description |
---|
ZKTopicMetadataCollector(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<ZKTopicMetadataCollectorContext> |
collectorContext()
Get the ZKTopicMetadataCollectorContext.
|
void |
disable()
Disable collector.
|
void |
enable(Map<String,TopicInfo> topicsWithInfo,
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 |
onTopicConfigChange(String topic,
kafka.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<ZKTopicMetadataCollectorContext> contextOptional)
Set the ZKTopicMetadataCollectorContext.
|
void |
shutdown()
Shutdown the collector.
|
public ZKTopicMetadataCollector(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, int epoch)
public void shutdown()
public boolean isActive()
public Optional<ZKTopicMetadataCollectorContext> collectorContext()
public void setCollectorContext(Optional<ZKTopicMetadataCollectorContext> contextOptional)
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, kafka.log.LogConfig newConfig, Properties updateProperties)
public void onBrokerDefaultConfigChange(kafka.server.KafkaConfig oldConfig, kafka.server.KafkaConfig newConfig)