fix

7 months ago · 9a5cc065b0
1 changed files with 0 additions and 1 deletions
--- 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()