diff --git a/weed/mq/sub_coordinator/consumer_group.go b/weed/mq/sub_coordinator/consumer_group.go index d298c0c41..6590bc5e2 100644 --- a/weed/mq/sub_coordinator/consumer_group.go +++ b/weed/mq/sub_coordinator/consumer_group.go @@ -128,7 +128,6 @@ func (cg *ConsumerGroup) BalanceConsumerGroupInstances(knownPartitionSlotToBroke }, }, } - println("sending response to", consumerGroupInstance.InstanceId, "...") consumerGroupInstance.ResponseChan <- response }