Fixes segmentio#874

kf6nux · May 16, 2024 · d0aa092 · d0aa092
1 parent ebca72e
commit d0aa092
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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()