diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-19 15:06:33 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-19 15:06:33 -0700 |
| commit | a2885512e184a6ab8e00fed5b6e4b0679d219230 (patch) | |
| tree | 5081ec5dd21e17d55f670ece1db14c298ce9ee2c | |
| parent | 8d02712c630d6f23ec6540e691939069959fd0b4 (diff) | |
| download | seaweedfs-a2885512e184a6ab8e00fed5b6e4b0679d219230.tar.xz seaweedfs-a2885512e184a6ab8e00fed5b6e4b0679d219230.zip | |
fix
| -rw-r--r-- | weed/mq/client/sub_client/connect_to_sub_coordinator.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/client/sub_client/connect_to_sub_coordinator.go b/weed/mq/client/sub_client/connect_to_sub_coordinator.go index e26997b08..094ce46ef 100644 --- a/weed/mq/client/sub_client/connect_to_sub_coordinator.go +++ b/weed/mq/client/sub_client/connect_to_sub_coordinator.go @@ -145,7 +145,7 @@ func (sub *TopicSubscriber) onEachPartition(assigned *mq_pb.BrokerPartitionAssig var lastErr error - for lastErr != nil { + for lastErr == nil { // glog.V(0).Infof("subscriber %s/%s/%s waiting for message", sub.ContentConfig.Namespace, sub.ContentConfig.Topic, sub.SubscriberConfig.ConsumerGroup) resp, err := subscribeClient.Recv() if err != nil { |