public class TopicCreationEvent extends MetadataCollectorEvent
LocalStore
, and emit incremental events for these changes.CACHE_BUILD_EVENT_TAG, collector, eventObserveTime, LOG, SNAPSHOT_EVENT_TAG, time
Constructor and Description |
---|
TopicCreationEvent(ZKTopicMetadataCollector collector,
Map<String,TopicInfo> newTopicWithInfo,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
String |
toString() |
context, emitDeltaEvent, emitSnapshotEvent, getLogConfigsForTopic, getTopicIdReplicaAssignmentFromZk, handleException, recordEventHandleError
public TopicCreationEvent(ZKTopicMetadataCollector collector, Map<String,TopicInfo> newTopicWithInfo, org.apache.kafka.common.utils.Time time)
public void run() throws CollectorContextNotInitializedException