public class SnapshotEvent extends MetadataCollectorEvent
LocalStore
and publish snapshot. It will schedule another
SnapshotEvent
after it done.CACHE_BUILD_EVENT_TAG, SNAPSHOT_EVENT_TAG
Constructor and Description |
---|
SnapshotEvent(ZKMetadataCollector collector,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
handleException
public SnapshotEvent(ZKMetadataCollector collector, org.apache.kafka.common.utils.Time time)