diff options
| -rw-r--r-- | weed/mq/client/sub_client/on_each_partition.go | 1 |
1 files changed, 0 insertions, 1 deletions
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() |