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()