public class CacheBuildEvent extends MetadataCollectorEvent
LocalStore
. It will only
process up to maxNumTopicsProcess
for each batch. It will append another
CacheBuildEvent
to the queue if there's remaining topics. Otherwise it will prepend
a SnapshotEvent
to the queue.CACHE_BUILD_EVENT_TAG, collector, eventObserveTime, LOG, SNAPSHOT_EVENT_TAG, time
Constructor and Description |
---|
CacheBuildEvent(ZKTopicMetadataCollector collector,
int maxNumTopicsProcess,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
String |
toString() |
context, emitDeltaEvent, emitSnapshotEvent, getLogConfigsForTopic, getTopicIdReplicaAssignmentFromZk, handleException, recordEventHandleError
public CacheBuildEvent(ZKTopicMetadataCollector collector, int maxNumTopicsProcess, org.apache.kafka.common.utils.Time time)