Merge pull request #65 from unistack-org/master

when CommitRecords commit next offset to move forward
twmb · Aug 22, 2021 · 841c44d · 841c44d
2 parents 4c20135 + 733848b
commit 841c44d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kgo/consumer_group.go b/pkg/kgo/consumer_group.go
@@ -1684,7 +1684,7 @@ func (cl *Client) CommitRecords(ctx context.Context, rs ...*Record) error {
 		}
 		toffsets[r.Partition] = EpochOffset{
 			r.LeaderEpoch,
-			r.Offset,
+			r.Offset + 1, // need to advice to next offset to move forward
 		}
 	}