public class KRaftTopicMetadataCollector extends Object implements org.apache.kafka.image.MetadataImageListener, TopicMetadataSnapshotCollector
Constructor and Description |
---|
KRaftTopicMetadataCollector(int snapshotInitDelay,
int snapshotInterval,
int maxTopicsInSnapshot,
String destTopic,
int nodeId) |
Modifier and Type | Method and Description |
---|---|
scala.Function0<scala.runtime.BoxedUnit> |
emitMetadataSnapshot()
Emit a topic metadata snapshot.
|
boolean |
isActive()
An active collector means it is emitting snapshots and change deltas.
|
void |
onLeaderUpdate(org.apache.kafka.raft.LeaderAndEpoch leader) |
void |
onMetadataImageUpdate(org.apache.kafka.image.MetadataDelta metadataDelta,
org.apache.kafka.image.MetadataImage newMetadataImage) |
void |
start()
Start collector, it does not necessarily mean this collector is immediately going to emit snapshots or change deltas.
|
void |
stop()
Stop collector, it will eventually stop emitting snapshots and change deltas.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
deregisterSnapshotTask, registerSnapshotTask
public KRaftTopicMetadataCollector(int snapshotInitDelay, int snapshotInterval, int maxTopicsInSnapshot, String destTopic, int nodeId)
public void start()
public void stop()
public boolean isActive()
public void onLeaderUpdate(org.apache.kafka.raft.LeaderAndEpoch leader)
onLeaderUpdate
in interface org.apache.kafka.image.MetadataImageListener
public void onMetadataImageUpdate(org.apache.kafka.image.MetadataDelta metadataDelta, org.apache.kafka.image.MetadataImage newMetadataImage)
onMetadataImageUpdate
in interface org.apache.kafka.image.MetadataImageListener
public scala.Function0<scala.runtime.BoxedUnit> emitMetadataSnapshot()
TopicMetadataSnapshotCollector
emitMetadataSnapshot
in interface TopicMetadataSnapshotCollector