diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index a24944122e710ce932224a09d972879090726a62..d252faba477e6dce299b6f6c949bb3d844920a4c 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -648,6 +648,7 @@ func (rmq *rocksmq) Consume(topicName string, groupName string, n int) ([]Consum return consumerMessage, nil } +// seek is used for internal call without the topicMu func (rmq *rocksmq) seek(topicName string, groupName string, msgID UniqueID) error { rmq.storeMu.Lock() defer rmq.storeMu.Unlock()