[skip ci]Add comments for RegisterConsumer (#9912)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
This commit is contained in:
yukun 2021-10-14 20:02:37 +08:00 committed by GitHub
parent a0d9991d6f
commit 83f1b75293
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -371,6 +371,7 @@ func (rmq *rocksmq) CreateConsumerGroup(topicName, groupName string) error {
return nil
}
// RegisterConsumer registers a consumer in rocksmq consumers
func (rmq *rocksmq) RegisterConsumer(consumer *Consumer) {
start := time.Now()
if vals, ok := rmq.consumers.Load(consumer.Topic); ok {