public final class KRaftSnapshotManager extends Object implements io.confluent.kafka.raft.SimpleRaftTracer
Modifier and Type | Method and Description |
---|---|
static KRaftSnapshotManager |
create(io.confluent.kafka.concurrent.EventExecutor executor,
TierObjectStore objectStore,
org.apache.kafka.common.utils.LogContext logContext,
Function<org.apache.kafka.common.TopicIdPartition,Optional<Path>> topicIdPath,
String clusterId)
Creates a new KRaft snapshot manager.
|
void |
nodeStartedUp(org.apache.kafka.common.TopicIdPartition tpId,
int epoch,
OptionalInt nodeId,
OptionalLong hwm,
long logStartOffset,
long logEndOffset,
SortedSet<org.apache.kafka.raft.OffsetAndEpoch> snapshotIds,
OptionalInt leaderId,
Set<Integer> currentVoters) |
void |
snapshotGenerated(org.apache.kafka.common.TopicIdPartition tpId,
int epoch,
OptionalInt nodeId,
OptionalLong hwm,
long logStartOffset,
long logEndOffset,
org.apache.kafka.raft.OffsetAndEpoch newSnapshotId,
OptionalInt leaderId,
Set<Integer> currentVoters) |
public void nodeStartedUp(org.apache.kafka.common.TopicIdPartition tpId, int epoch, OptionalInt nodeId, OptionalLong hwm, long logStartOffset, long logEndOffset, SortedSet<org.apache.kafka.raft.OffsetAndEpoch> snapshotIds, OptionalInt leaderId, Set<Integer> currentVoters)
nodeStartedUp
in interface io.confluent.kafka.raft.RaftTracer
nodeStartedUp
in interface io.confluent.kafka.raft.SimpleRaftTracer
public void snapshotGenerated(org.apache.kafka.common.TopicIdPartition tpId, int epoch, OptionalInt nodeId, OptionalLong hwm, long logStartOffset, long logEndOffset, org.apache.kafka.raft.OffsetAndEpoch newSnapshotId, OptionalInt leaderId, Set<Integer> currentVoters)
snapshotGenerated
in interface io.confluent.kafka.raft.RaftTracer
snapshotGenerated
in interface io.confluent.kafka.raft.SimpleRaftTracer
public static KRaftSnapshotManager create(io.confluent.kafka.concurrent.EventExecutor executor, TierObjectStore objectStore, org.apache.kafka.common.utils.LogContext logContext, Function<org.apache.kafka.common.TopicIdPartition,Optional<Path>> topicIdPath, String clusterId)
executor
- event executor to execute all actionsobjectStore
- object stored used to upload checkpoints filelogContext
- context for log messagestopicIdPath
- returns the log dir path for a given topic id