diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_reader.go b/internal/util/rocksmq/server/rocksmq/rocksmq_reader.go index f42bdbf5b454bd7c2ce0dab10689fe988f1a3e9c..73c17b8755d8606e5b292f0586ee5103de8a254f 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_reader.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_reader.go @@ -35,6 +35,7 @@ type rocksmqReader struct { readerMutex chan struct{} } +//Seek seek the rocksmq reader to the pointed position func (rr *rocksmqReader) Seek(msgID UniqueID) { //nolint:govet rr.currentID = msgID select {