public class TopicConfigChangeEvent extends MetadataCollectorEvent
TopicConfigChangeEvent
:
1. adding a dynamic topic config
2. deleting a dynamic topic config
The event will handle both type of changes and reflect the topic config change in the
LocalStore
, and emit an incremental event for the change.CACHE_BUILD_EVENT_TAG, SNAPSHOT_EVENT_TAG
Constructor and Description |
---|
TopicConfigChangeEvent(ZKMetadataCollector collector,
String logicalClusterId,
String topic,
org.apache.kafka.storage.internals.log.LogConfig newConfig,
Properties updateProperties,
org.apache.kafka.common.utils.Time time) |
public TopicConfigChangeEvent(ZKMetadataCollector collector, String logicalClusterId, String topic, org.apache.kafka.storage.internals.log.LogConfig newConfig, Properties updateProperties, org.apache.kafka.common.utils.Time time)
public void handleException(Throwable e)
handleException
in interface org.apache.kafka.queue.EventQueue.Event
handleException
in class MetadataCollectorEvent