diff --git a/src/v/cloud_storage/remote_partition.cc b/src/v/cloud_storage/remote_partition.cc index 3a000e72a76c1..69263323ef4be 100644 --- a/src/v/cloud_storage/remote_partition.cc +++ b/src/v/cloud_storage/remote_partition.cc @@ -16,6 +16,7 @@ #include "cloud_storage/types.h" #include "storage/parser_errc.h" #include "storage/types.h" +#include "utils/gate_guard.h" #include "utils/retry_chain_node.h" #include "utils/stream_utils.h" @@ -501,6 +502,7 @@ remote_partition::get_term_last_offset(model::term_id term) const { ss::future> remote_partition::aborted_transactions(offset_range offsets) { + gate_guard(_gate); // Here we have to use kafka offsets to locate the segments and // redpanda offsets to extract aborted transactions metadata because // tx-manifests contains redpanda offsets.