From a2885512e184a6ab8e00fed5b6e4b0679d219230 Mon Sep 17 00:00:00 2001 From: chrislu Date: Sun, 19 May 2024 15:06:33 -0700 Subject: [PATCH] fix --- weed/mq/client/sub_client/connect_to_sub_coordinator.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 {