From 4a8619619bb374b8d01242e25135060f7b0eda0e Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 21 Oct 2021 22:43:21 +0800 Subject: [PATCH] [skip ci]Add comments for rocksmq (#10388) 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 34e5103461..245aff5721 100644 --- a/internal/util/rocksmq/client/rocksmq/consumer_impl.go +++ b/internal/util/rocksmq/client/rocksmq/consumer_impl.go @@ -98,6 +98,7 @@ func (c *consumer) Chan() <-chan ConsumerMessage { return c.messageCh } +// Seek seek rocksmq position to id and notify consumer to consume func (c *consumer) Seek(id UniqueID) error { //nolint:govet err := c.client.server.Seek(c.topic, c.consumerName, id) if err != nil {