public abstract class MetadataCollectorEvent extends Object implements org.apache.kafka.queue.EventQueue.Event
Modifier and Type | Field and Description |
---|---|
static String |
CACHE_BUILD_EVENT_TAG |
static String |
SNAPSHOT_EVENT_TAG |
Constructor and Description |
---|
MetadataCollectorEvent(ZKMetadataCollector collector,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
handleException(Throwable e) |
public static final String SNAPSHOT_EVENT_TAG
public static final String CACHE_BUILD_EVENT_TAG
public MetadataCollectorEvent(ZKMetadataCollector collector, org.apache.kafka.common.utils.Time time)
public void handleException(Throwable e)
handleException
in interface org.apache.kafka.queue.EventQueue.Event