[skip ci]Add comments for DestroyConsumerGroup (#10029)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-16 22:03:09 +08:00 · 2021-10-16 22:03:09 +08:00 · e8d5a1ee5f
parent 759603671c
commit e8d5a1ee5f
1 changed files with 1 additions and 0 deletions
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@ -391,6 +391,7 @@ func (rmq *rocksmq) RegisterConsumer(consumer *Consumer) {
 	log.Debug("Rocksmq register consumer successfully ", zap.String("topic", consumer.Topic), zap.Int64("elapsed", time.Since(start).Milliseconds()))
 }

+// DestroyConsumerGroup removes a consumer group from rocksdb_kv
 func (rmq *rocksmq) DestroyConsumerGroup(topicName, groupName string) error {
 	start := time.Now()
 	ll, ok := topicMu.Load(topicName)