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) {