public class TopicPartitionChangeEvent extends MetadataCollectorEvent
LocalStore
, and emit an
incremental event for the change.CACHE_BUILD_EVENT_TAG, collector, eventObservedTimeMillis, LOG, SNAPSHOT_EVENT_TAG, time
Constructor and Description |
---|
TopicPartitionChangeEvent(ZKTopicMetadataCollector collector,
String logicalClusterId,
String topic,
int newPartition,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
String |
toString() |
context, emitDeltaEvent, emitSnapshotEvent, filterCatalogConfigOverride, getLogConfigsForTopic, getTopicIdReplicaAssignmentFromZk, handleException, recordEventHandleError
public TopicPartitionChangeEvent(ZKTopicMetadataCollector collector, String logicalClusterId, String topic, int newPartition, org.apache.kafka.common.utils.Time time)