From 6a1eff3487a2e4a6d0dd29b774ff4d0acff96a95 Mon Sep 17 00:00:00 2001 From: congqixia Date: Sun, 25 Jun 2023 14:16:44 +0800 Subject: [PATCH] Fix kafka consumer double close (#25051) Signed-off-by: Congqi Xia --- pkg/mq/msgstream/mqwrapper/kafka/kafka_consumer.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/pkg/mq/msgstream/mqwrapper/kafka/kafka_consumer.go b/pkg/mq/msgstream/mqwrapper/kafka/kafka_consumer.go index 1a83bb466..f2bdb4424 100644 --- a/pkg/mq/msgstream/mqwrapper/kafka/kafka_consumer.go +++ b/pkg/mq/msgstream/mqwrapper/kafka/kafka_consumer.go @@ -251,7 +251,6 @@ func (kc *Consumer) CheckTopicValid(topic string) error { func (kc *Consumer) Close() { kc.closeOnce.Do(func() { close(kc.closeCh) - kc.wg.Wait() - kc.c.Close() + kc.wg.Wait() // wait worker exist and close the client }) } -- GitLab