From e8d5a1ee5fc68d21451a609e0a858c51b00d6f2d Mon Sep 17 00:00:00 2001 From: yukun Date: Sat, 16 Oct 2021 22:03:09 +0800 Subject: [PATCH] [skip ci]Add comments for DestroyConsumerGroup (#10029) 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 c9fb5c4c5d..d769745c57 100644 --- 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)