public class CollectorStartupEvent extends MetadataCollectorEvent
CacheBuildEvent
to build the topic MetadataEvent cache in the context.CACHE_BUILD_EVENT_TAG, SNAPSHOT_EVENT_TAG
Constructor and Description |
---|
CollectorStartupEvent(ZKMetadataCollector collector,
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 CollectorStartupEvent(ZKMetadataCollector collector, 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 void handleException(Throwable e)
handleException
in interface org.apache.kafka.queue.EventQueue.Event
handleException
in class MetadataCollectorEvent