From 6a167f8579f88c97d2ff84b7d3f312b95640a86a Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 23 Nov 2021 19:15:22 +0800 Subject: [PATCH] Fix rocksmq produce hang when do search repeatedly (#12225) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 962e3be8ef..8261dcf745 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -597,6 +597,9 @@ func (rmq *rocksmq) Consume(topicName string, groupName string, n int) ([]Consum log.Debug("RocksMQ: load " + metaKey + " failed") return nil, err } + if currentID == "" { + return nil, fmt.Errorf("currentID of topicName=%s, groupName=%s not exist", topicName, groupName) + } readOpts := gorocksdb.NewDefaultReadOptions() defer readOpts.Destroy()