diff --git a/internal/util/rocksmq/client/rocksmq/reader_impl.go b/internal/util/rocksmq/client/rocksmq/reader_impl.go index 0f2d48c0e6..d075f4b910 100644 --- a/internal/util/rocksmq/client/rocksmq/reader_impl.go +++ b/internal/util/rocksmq/client/rocksmq/reader_impl.go @@ -79,6 +79,7 @@ func (r *reader) Close() { r.c.server.CloseReader(r.topic, r.name) } +// Seek seek the reader to the position of message id func (r *reader) Seek(msgID UniqueID) error { //nolint:govet r.c.server.ReaderSeek(r.topic, r.name, msgID) return nil