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, SNAPSHOT_EVENT_TAG
Constructor and Description |
---|
CacheBuildEvent(ZKMetadataCollector collector,
int maxNumEntitiesProcess,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
String |
toString() |
handleException