Skip to content

Commit ecfa185

Browse files
committed
direct_consumer/api_types: fix invalid lso
Changes the initial state of last_stable_offset to be invalid_lso Will research the proper 'invalid' offsets for the others in a followon.
1 parent fb562df commit ecfa185

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/v/kafka/client/direct_consumer/api_types.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ struct source_partition_offsets {
9292
// The source partition's log high watermark
9393
kafka::offset high_watermark{-1};
9494
// The source partition's log last stable offset
95-
kafka::offset last_stable_offset{-1};
95+
kafka::offset last_stable_offset{model::offset_cast(model::invalid_lso)};
9696
// The timestamp that the fetch response was received by the client
9797
ss::lowres_clock::time_point last_offset_update_timestamp{};
9898

0 commit comments

Comments
 (0)