Skip to content

Commit 5a7fc1e

Browse files
committed
fix consume not actually printing specified offset
1 parent 8dfe1f5 commit 5a7fc1e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/saluki/consume.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ def consume(
4444
start = offset
4545
else:
4646
if offset is not None:
47-
start = offset - num_messages
47+
start = offset - num_messages + 1
4848
else:
4949
start = (
5050
c.get_watermark_offsets(TopicPartition(topic, partition), cached=False)[

0 commit comments

Comments
 (0)