mirror of https://github.com/milvus-io/milvus.git
[skip ci]Add comments for ExistConsumerGroup (#9832)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/9834/head
parent
67d38d6cf1
commit
d2e2e0a63c
|
@ -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) {
|
||||
|
|
Loading…
Reference in New Issue