[skip ci]Add comments for rocksmq produce (#10030)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-16 22:05:04 +08:00 · 2021-10-16 22:05:04 +08:00 · 65a1ae0210
parent e8d5a1ee5f
commit 65a1ae0210
1 changed files with 1 additions and 0 deletions
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@ -427,6 +427,7 @@ func (rmq *rocksmq) DestroyConsumerGroup(topicName, groupName string) error {
 	return nil
 }

+// Produce produces messages for topic and updates page infos for retention
 func (rmq *rocksmq) Produce(topicName string, messages []ProducerMessage) ([]UniqueID, error) {
 	ll, ok := topicMu.Load(topicName)
 	if !ok {