public class KRaftMetadataCollector extends Object implements org.apache.kafka.image.publisher.MetadataPublisher
Constructor and Description |
---|
KRaftMetadataCollector(org.apache.kafka.common.metrics.Metrics metrics,
int snapshotInitDelaySec,
int snapshotIntervalSec,
int maxEntitiesInSnapshot,
String destTopic,
int nodeId,
kafka.server.KafkaConfig kafkaConfig,
org.apache.kafka.common.utils.Time time,
String clusterId) |
Modifier and Type | Method and Description |
---|---|
Runnable |
emitMetadataSnapshot() |
boolean |
isActive()
An active collector means it is emitting snapshots and change deltas.
|
String |
name() |
void |
onControllerChange(org.apache.kafka.raft.LeaderAndEpoch leader)
Called on each change to leadership.
|
void |
onMetadataUpdate(org.apache.kafka.image.MetadataDelta metadataDelta,
org.apache.kafka.image.MetadataImage newMetadataImage,
org.apache.kafka.image.loader.LoaderManifest loaderManifest) |
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 KRaftMetadataCollector(org.apache.kafka.common.metrics.Metrics metrics, int snapshotInitDelaySec, int snapshotIntervalSec, int maxEntitiesInSnapshot, String destTopic, int nodeId, kafka.server.KafkaConfig kafkaConfig, org.apache.kafka.common.utils.Time time, String clusterId)
public String name()
name
in interface org.apache.kafka.image.publisher.MetadataPublisher
public void start()
public void stop() throws InterruptedException
InterruptedException
public boolean isActive()
public void onControllerChange(org.apache.kafka.raft.LeaderAndEpoch leader)
onControllerChange
in interface org.apache.kafka.image.publisher.MetadataPublisher
public void onMetadataUpdate(org.apache.kafka.image.MetadataDelta metadataDelta, org.apache.kafka.image.MetadataImage newMetadataImage, org.apache.kafka.image.loader.LoaderManifest loaderManifest)
onMetadataUpdate
in interface org.apache.kafka.image.publisher.MetadataPublisher
public Runnable emitMetadataSnapshot()