We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3f68080 commit c369952Copy full SHA for c369952
conn.go
@@ -863,7 +863,7 @@ func (c *Conn) ReadBatchWith(cfg ReadBatchConfig) *Batch {
863
864
var msgs *messageSetReader
865
if err == nil {
866
- if highWaterMark == offset {
+ if highWaterMark == offset || remain == 0 {
867
msgs = &messageSetReader{empty: true}
868
} else {
869
msgs, err = newMessageSetReader(&c.rbuf, remain)
0 commit comments