From f0b9e163a025077b8a370deabaf5773409eb67a1 Mon Sep 17 00:00:00 2001 From: chrislu Date: Wed, 29 May 2024 16:18:02 -0700 Subject: [PATCH] avoid nil stopChan --- weed/mq/sub_coordinator/consumer_group.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/weed/mq/sub_coordinator/consumer_group.go b/weed/mq/sub_coordinator/consumer_group.go index fcb305b33..247434288 100644 --- a/weed/mq/sub_coordinator/consumer_group.go +++ b/weed/mq/sub_coordinator/consumer_group.go @@ -24,6 +24,7 @@ func NewConsumerGroup(t *mq_pb.Topic, reblanceSeconds int32, filerClientAccessor topic: topic.FromPbTopic(t), ConsumerGroupInstances: cmap.New[*ConsumerGroupInstance](), filerClientAccessor: filerClientAccessor, + stopCh: make(chan struct{}), } if conf, err := cg.filerClientAccessor.ReadTopicConfFromFiler(cg.topic); err == nil { var partitions []topic.Partition @@ -53,8 +54,8 @@ func NewConsumerGroup(t *mq_pb.Topic, reblanceSeconds int32, filerClientAccessor Message: &mq_pb.SubscriberToSubCoordinatorResponse_Assignment_{ Assignment: &mq_pb.SubscriberToSubCoordinatorResponse_Assignment{ PartitionAssignment: &mq_pb.BrokerPartitionAssignment{ - Partition: adjustment.partition.ToPbPartition(), - LeaderBroker: assignment.LeaderBroker, + Partition: adjustment.partition.ToPbPartition(), + LeaderBroker: assignment.LeaderBroker, FollowerBroker: assignment.FollowerBroker, }, },