bugfix sink: reset needSeqReset

twmb · Apr 25, 2021 · 2b9b8ca · 2b9b8ca
1 parent 314de8e
commit 2b9b8ca
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/kgo/sink.go b/pkg/kgo/sink.go
@@ -1327,6 +1327,7 @@ func (r *produceRequest) tryAddBatch(produceVersion int32, recBuf *recBuf, batch
 	}
 
 	if recBuf.needSeqReset && recBuf.batches[0] == batch {
+		recBuf.needSeqReset = false
 		recBuf.seq = 0
 		recBuf.batch0Seq = 0
 	}