fix: avoid return io.UnexpectedEOF error while remain is zero

resolves segmentio#1286
acynothia · May 2, 2024 · 841258d · 841258d
1 parent ebca72e
commit 841258d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/conn.go b/conn.go
@@ -858,7 +858,7 @@ func (c *Conn) ReadBatchWith(cfg ReadBatchConfig) *Batch {
 
 	var msgs *messageSetReader
 	if err == nil {
-		if highWaterMark == offset {
+		if highWaterMark == offset || remain == 0 {
 			msgs = &messageSetReader{empty: true}
 		} else {
 			msgs, err = newMessageSetReader(&c.rbuf, remain)