public class KRaftTopicMetadataCollector extends Object implements org.apache.kafka.image.MetadataImageListener
Constructor and Description |
---|
KRaftTopicMetadataCollector(org.apache.kafka.common.metrics.Metrics metrics,
int snapshotInitDelay,
int snapshotInterval,
int maxTopicsInSnapshot,
String destTopic,
int nodeId,
kafka.server.KafkaConfig kafkaConfig,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
scala.Function0<scala.runtime.BoxedUnit> |
emitMetadataSnapshot() |
boolean |
isActive()
An active collector means it is emitting snapshots and change deltas.
|
void |
onLeaderUpdate(org.apache.kafka.raft.LeaderAndEpoch leader)
Called on each change to leadership.
|
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.
|
public KRaftTopicMetadataCollector(org.apache.kafka.common.metrics.Metrics metrics, int snapshotInitDelay, int snapshotInterval, int maxTopicsInSnapshot, String destTopic, int nodeId, kafka.server.KafkaConfig kafkaConfig, org.apache.kafka.common.utils.Time time)
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()