public class MirrorTopicChangeEvent extends MetadataCollectorEvent
CACHE_BUILD_EVENT_TAG, SNAPSHOT_EVENT_TAG
Constructor and Description |
---|
MirrorTopicChangeEvent(ZKMetadataCollector collector,
String logicalClusterId,
String topic,
String mirrorTopicState,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
String |
toString() |
handleException
public MirrorTopicChangeEvent(ZKMetadataCollector collector, String logicalClusterId, String topic, String mirrorTopicState, org.apache.kafka.common.utils.Time time)