From a0b442931249b91affd5f2dc9444598b464e6ff3 Mon Sep 17 00:00:00 2001
From: Piotr Piotrowski <piotr@synadia.com>
Date: Wed, 19 Mar 2025 16:14:09 +0100
Subject: [PATCH] [FIXED] Possible panic in Conusmer.Fetch

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
---
 jetstream/pull.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/jetstream/pull.go b/jetstream/pull.go
index 2bc3bf5c1..d255e61c4 100644
--- a/jetstream/pull.go
+++ b/jetstream/pull.go
@@ -810,6 +810,9 @@ func (p *pullConsumer) fetch(req *pullRequest) (MessageBatch, error) {
 				meta, err := msg.Metadata()
 				if err != nil {
 					res.err = fmt.Errorf("parsing message metadata: %s", err)
+					res.done = true
+					res.Unlock()
+					return
 				}
 				res.sseq = meta.Sequence.Stream
 				receivedMsgs++