From 53f72f12466362e4477e56a7f1d7821608a6237a Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Wed, 12 Mar 2025 16:59:43 +0300
Subject: [PATCH] fixup panic

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

diff --git a/subscriber.go b/subscriber.go
index db86984..1710dc7 100644
--- a/subscriber.go
+++ b/subscriber.go
@@ -160,7 +160,10 @@ func (s *Subscriber) killConsumers(ctx context.Context, lost map[string][]int32)
 	for topic, partitions := range lost {
 		for _, partition := range partitions {
 			tps := tp{topic, partition}
-			pc := s.consumers[tps]
+			pc, ok := s.consumers[tps]
+			if !ok {
+				continue
+			}
 			delete(s.consumers, tps)
 			close(pc.quit)
 			if s.kopts.Logger.V(logger.DebugLevel) {