From 9a5cc065b02c721bbf99ea24c713641fc7bdcbcd Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Thu, 30 May 2024 08:29:06 -0700
Subject: [PATCH] fix

---
 weed/mq/client/sub_client/on_each_partition.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/weed/mq/client/sub_client/on_each_partition.go b/weed/mq/client/sub_client/on_each_partition.go
index d0222c370..5dcac4eb3 100644
--- a/weed/mq/client/sub_client/on_each_partition.go
+++ b/weed/mq/client/sub_client/on_each_partition.go
@@ -66,7 +66,6 @@ func (sub *TopicSubscriber) onEachPartition(assigned *mq_pb.BrokerPartitionAssig
 				case <-stopCh:
 					subscribeClient.CloseSend()
 					return
-				case ack := <-partitionOffsetChan:
 				case ack, ok := <-partitionOffsetChan:
 					if !ok {
 						subscribeClient.CloseSend()