diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-30 08:29:06 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-30 08:29:06 -0700 |
| commit | 9a5cc065b02c721bbf99ea24c713641fc7bdcbcd (patch) | |
| tree | 208a58edb2a7f09c4f0786fd6c03601aad7f165c | |
| parent | 23a72db1df85a275a5f63a8b76d1990667434994 (diff) | |
| download | seaweedfs-9a5cc065b02c721bbf99ea24c713641fc7bdcbcd.tar.xz seaweedfs-9a5cc065b02c721bbf99ea24c713641fc7bdcbcd.zip | |
fix
| -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() |