diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
index 5cf2211f8c..f1137972a8 100644
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@@ -166,6 +166,10 @@ func NewRocksMQ(name string, idAllocator allocator.GIDAllocator) (*rocksmq, erro
 	return rmq, nil
 }
 
+// Close step:
+// 1. Stop retention
+// 2. Destroy all consumer groups and topics
+// 3. Close rocksdb instance
 func (rmq *rocksmq) Close() {
 	rmq.stopRetention()
 	rmq.storeMu.Lock()