diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 32157c7aebbb11f971be6283c70d1b5cb37f5da1..e2529d3e5e1edb435c7d9e0c05a5cbf8d17ac570 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -717,7 +717,7 @@ func (rmq *rocksmq) seek(topicName string, groupName string, msgID UniqueID) err key := constructCurrentID(topicName, groupName) if !rmq.checkKeyExist(key) { log.Warn("RocksMQ: channel " + key + " not exists") - return fmt.Errorf("ConsumerGroup %s, channel %s not exists", groupName, topicName) + return fmt.Errorf("consumerGroup %s, channel %s not exists", groupName, topicName) } storeKey, err := combKey(topicName, msgID) if err != nil {