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 |
protected ZKTopicMetadataCollector |
collector |
protected long |
eventObserveTime |
protected static org.slf4j.Logger |
LOG |
static String |
SNAPSHOT_EVENT_TAG |
protected org.apache.kafka.common.utils.Time |
time |
Constructor and Description |
---|
MetadataCollectorEvent(ZKTopicMetadataCollector collector,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
protected ZKTopicMetadataCollectorContext |
context()
Get the controller context.
|
protected void |
emitDeltaEvent(ZKTopicMetadataCollectorContext context,
io.confluent.protobuf.events.catalog.v1.MetadataChange metadataChange) |
protected void |
emitSnapshotEvent(ZKTopicMetadataCollectorContext context,
io.confluent.protobuf.events.catalog.v1.MetadataChange metadataChange,
int page,
int total) |
protected Optional<kafka.log.LogConfig> |
getLogConfigsForTopic(ZKTopicMetadataCollectorContext context,
String topic)
Given a topic name, query zookeeper to get the topic configuration for this topic.
|
protected kafka.zk.TopicZNode.TopicIdReplicaAssignment |
getTopicIdReplicaAssignmentFromZk(ZKTopicMetadataCollectorContext context,
String topic) |
void |
handleException(Throwable e) |
protected void |
recordEventHandleError() |
protected static final org.slf4j.Logger LOG
protected ZKTopicMetadataCollector collector
protected long eventObserveTime
protected final org.apache.kafka.common.utils.Time time
public static final String SNAPSHOT_EVENT_TAG
public static final String CACHE_BUILD_EVENT_TAG
public MetadataCollectorEvent(ZKTopicMetadataCollector collector, org.apache.kafka.common.utils.Time time)
public void handleException(Throwable e)
handleException
in interface org.apache.kafka.queue.EventQueue.Event
protected void recordEventHandleError()
protected ZKTopicMetadataCollectorContext context() throws CollectorContextNotInitializedException
CollectorContextNotInitializedException
- if context doesn't existprotected Optional<kafka.log.LogConfig> getLogConfigsForTopic(ZKTopicMetadataCollectorContext context, String topic) throws TopicConfigFetchRequestException
LogConfig
object for this topic. If empty, the topic
config is no longer exists in Zookeeper.TopicConfigFetchRequestException
protected kafka.zk.TopicZNode.TopicIdReplicaAssignment getTopicIdReplicaAssignmentFromZk(ZKTopicMetadataCollectorContext context, String topic)
protected void emitDeltaEvent(ZKTopicMetadataCollectorContext context, io.confluent.protobuf.events.catalog.v1.MetadataChange metadataChange)
protected void emitSnapshotEvent(ZKTopicMetadataCollectorContext context, io.confluent.protobuf.events.catalog.v1.MetadataChange metadataChange, int page, int total)