From d2e2e0a63c77f897122ebf4e8f1faa77bb1aee52 Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 13 Oct 2021 20:44:33 +0800 Subject: [PATCH] [skip ci]Add comments for ExistConsumerGroup (#9832) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 78c0cf044a..f230b61451 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -338,6 +338,7 @@ func (rmq *rocksmq) DestroyTopic(topicName string) error { return nil } +// ExistConsumerGroup check if a consumer exists and return the existed consumer func (rmq *rocksmq) ExistConsumerGroup(topicName, groupName string) (bool, *Consumer) { key := constructCurrentID(topicName, groupName) if rmq.checkKeyExist(key) {