From af7a5ca50f0114e30a043d3ad2e784f2f13cade1 Mon Sep 17 00:00:00 2001
From: yukun <kun.yu@zilliz.com>
Date: Mon, 1 Nov 2021 23:02:33 +0800
Subject: [PATCH] [skip ci]Add rocksmq client comments (#11052)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
---
 internal/util/rocksmq/client/rocksmq/client_impl.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/util/rocksmq/client/rocksmq/client_impl.go b/internal/util/rocksmq/client/rocksmq/client_impl.go
index 1e5cedaa6e..38bf53b860 100644
--- a/internal/util/rocksmq/client/rocksmq/client_impl.go
+++ b/internal/util/rocksmq/client/rocksmq/client_impl.go
@@ -64,6 +64,7 @@ func (c *client) CreateProducer(options ProducerOptions) (Producer, error) {
 	return producer, nil
 }
 
+// Subscribe create a rocksmq consumer and start consume in a goroutine
 func (c *client) Subscribe(options ConsumerOptions) (Consumer, error) {
 	// Create a consumer
 	if reflect.ValueOf(c.server).IsNil() {