From 319b3282d9a06a9e87ac62a5f28c5df1f8916c2c Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 21 Oct 2021 22:45:22 +0800 Subject: [PATCH] [skip ci]Add comments for rocksmq consumer_impl (#10389) Signed-off-by: fishpenguin --- internal/util/rocksmq/client/rocksmq/consumer_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/client/rocksmq/consumer_impl.go b/internal/util/rocksmq/client/rocksmq/consumer_impl.go index 245aff5721..6f68c7e4a9 100644 --- a/internal/util/rocksmq/client/rocksmq/consumer_impl.go +++ b/internal/util/rocksmq/client/rocksmq/consumer_impl.go @@ -108,6 +108,7 @@ func (c *consumer) Seek(id UniqueID) error { //nolint:govet return nil } +// Close destroy current consumer in rocksmq func (c *consumer) Close() { err := c.client.server.DestroyConsumerGroup(c.topic, c.consumerName) if err != nil {