[skip ci]Add comments for rocksmq CreateTopic (#9733)

Signed-off-by: N fishpenguin <kun.yu@zilliz.com>

[skip ci]Add comments for rocksmq CreateTopic (#9733)
Signed-off-by: N fishpenguin <kun.yu@zilliz.com>
55c615b4 · yukun · GitHub · 75431221 · 55c615b4
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

internal/util/rocksmq/server/rocksmq/rocksmq_impl.go internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +1 -0

未找到文件。
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@@ -211,6 +211,7 @@ func (rmq *rocksmq) checkKeyExist(key string) bool {
 	return val != ""
 }

+// CreateTopic writes initialized messages for topic in rocksdb
 func (rmq *rocksmq) CreateTopic(topicName string) error {
 	start := time.Now()
 	beginKey := topicName + "/begin_id"