From fe5d474f369785afad360031c1e2d48b3b780a25 Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Tue, 2 Dec 2025 21:46:03 +0300
Subject: [PATCH] fixup error

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

diff --git a/subscriber.go b/subscriber.go
index 8bd6580..df88d35 100644
--- a/subscriber.go
+++ b/subscriber.go
@@ -123,7 +123,7 @@ func (s *Subscriber) poll(ctx context.Context) {
 				c := s.consumers[tps]
 				s.mu.Unlock()
 				if c != nil {
-					c.recs <- newErrorFetchTopicPartition(kgo.ErrClientClosed, t, p)
+					c.recs <- newErrorFetchTopicPartition(err, t, p)
 				}
 			})