From d0aa092d59bf08ab943a948517d2854a6815989c Mon Sep 17 00:00:00 2001
From: Jen Zarzycka <kf6nux@users.noreply.github.com>
Date: Wed, 15 May 2024 20:53:37 -0700
Subject: [PATCH] Fixes #874

---
 message_reader.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/message_reader.go b/message_reader.go
index a0a0385ef..3d545b9d5 100644
--- a/message_reader.go
+++ b/message_reader.go
@@ -135,6 +135,11 @@ func (r *messageSetReader) readMessage(min int64, key readBytesFunc, val readByt
 		// Set an invalid value so that it can be ignored
 		lastOffset = -1
 	case 2:
+		for ; r.count == 0; err = r.readHeader() {
+			if err != nil {
+				return
+			}
+		}
 		offset, lastOffset, timestamp, headers, err = r.readMessageV2(min, key, val)
 	default:
 		err = r.header.badMagic()