From d000ac6843b87a16ad03a23e9c8d9e85cdbea5d7 Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Tue, 2 Dec 2025 21:35:35 +0300
Subject: [PATCH] pass errors from broker to subscribers

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 subscriber.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/subscriber.go b/subscriber.go
index 00ab5cc..8bd6580 100644
--- a/subscriber.go
+++ b/subscriber.go
@@ -352,6 +352,8 @@ func (pc *consumer) newErrorMessage(err error, t string, p int32) *kgoMessage {
 		pm = &kgoMessage{}
 	}
 
+	pm.ack = false
+	pm.body = nil
 	pm.err = err
 	pm.topic = t
 	pm.hdr = metadata.New(2)