From 841258daac07aa09fdac67652fa45bee7c6375f5 Mon Sep 17 00:00:00 2001
From: Astone <11812510+acynothia@users.noreply.github.com>
Date: Thu, 2 May 2024 17:29:33 +0800
Subject: [PATCH] fix: avoid return io.UnexpectedEOF error while remain is zero

resolves #1286
---
 conn.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/conn.go b/conn.go
index 2b51afbd..faa2fb54 100644
--- 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)