diff --git a/src/v/kafka/server/handlers/list_offsets.cc b/src/v/kafka/server/handlers/list_offsets.cc index 72f27c3e746a..54c5a52cd1db 100644 --- a/src/v/kafka/server/handlers/list_offsets.cc +++ b/src/v/kafka/server/handlers/list_offsets.cc @@ -132,7 +132,7 @@ static ss::future list_offsets_partition( auto res = co_await kafka_partition->timequery(storage::timequery_config{ kafka_partition->start_offset(), timestamp, - offset, + model::prev_offset(offset), kafka_read_priority(), {model::record_batch_type::raft_data}, octx.rctx.abort_source().local()});