Skip to content

Commit

Permalink
Merge pull request #24618 from mmaslankaprv/fix-recovered-topic-offse…
Browse files Browse the repository at this point in the history
…t-delta

r/utils: fixed setting log start delta in snapshot
  • Loading branch information
mmaslankaprv authored Dec 20, 2024
2 parents be58f47 + e7ea155 commit 1c93893
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions src/v/raft/consensus_utils.cc
Original file line number Diff line number Diff line change
Expand Up @@ -377,7 +377,8 @@ ss::future<> create_raft_state_for_pre_existing_partition(
model::offset min_rp_offset,
model::offset max_rp_offset,
model::term_id last_included_term,
std::vector<raft::vnode> initial_nodes) {
std::vector<raft::vnode> initial_nodes,
model::offset_delta log_start_delta) {
// Prepare Raft state in kvstore
vlog(
raftlog.debug,
Expand All @@ -403,7 +404,7 @@ ss::future<> create_raft_state_for_pre_existing_partition(
.version = raft::snapshot_metadata::current_version,
.latest_configuration = std::move(group_config),
.cluster_time = ss::lowres_clock::now(),
.log_start_delta = raft::offset_translator_delta{0},
.log_start_delta = offset_translator_delta{log_start_delta},
};

vlog(
Expand Down Expand Up @@ -458,7 +459,8 @@ ss::future<> bootstrap_pre_existing_partition(
min_rp_offset,
max_rp_offset,
last_included_term,
initial_nodes);
initial_nodes,
model::offset_delta{ot_state->delta(min_rp_offset)});
}

} // namespace raft::details

0 comments on commit 1c93893

Please sign in to comment.