public final class KRaftSnapshotManager extends Object implements io.confluent.kafka.raft.SimpleRaftTracer
Modifier and Type | Field and Description |
---|---|
static String |
KEY_PREFIX |
Modifier and Type | Method and Description |
---|---|
static KRaftSnapshotManager |
create(io.confluent.kafka.concurrent.EventExecutor executor,
TierObjectStore objectStore,
KRaftSnapshotMetrics metrics,
org.apache.kafka.common.utils.LogContext logContext,
Function<org.apache.kafka.common.TopicIdPartition,Optional<Path>> topicIdPath,
String clusterId,
int nodeId,
Supplier<Boolean> deleteEnable,
Supplier<Long> retentionMs,
org.apache.kafka.common.utils.Time time)
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 static final String KEY_PREFIX
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, KRaftSnapshotMetrics metrics, org.apache.kafka.common.utils.LogContext logContext, Function<org.apache.kafka.common.TopicIdPartition,Optional<Path>> topicIdPath, String clusterId, int nodeId, Supplier<Boolean> deleteEnable, Supplier<Long> retentionMs, org.apache.kafka.common.utils.Time time)
executor
- event executor to execute all actionsobjectStore
- object stored used to upload checkpoints filemetrics
- snapshot metricslogContext
- context for log messagestopicIdPath
- returns the log dir path for a given topic idclusterId
- cluster idnodeId
- node iddeleteEnable
- configuration flag for enabling deletion of snapshotsretentionMs
- retention config in ms for each snapshottime
- time