未验证 提交 00f42b7e 编写于 作者: Y yukun 提交者: GitHub

[skip ci]Fix golint for rocksmq (#12810)

Signed-off-by: Nfishpenguin <kun.yu@zilliz.com>
上级 6320f92f
...@@ -717,7 +717,7 @@ func (rmq *rocksmq) seek(topicName string, groupName string, msgID UniqueID) err ...@@ -717,7 +717,7 @@ func (rmq *rocksmq) seek(topicName string, groupName string, msgID UniqueID) err
key := constructCurrentID(topicName, groupName) key := constructCurrentID(topicName, groupName)
if !rmq.checkKeyExist(key) { if !rmq.checkKeyExist(key) {
log.Warn("RocksMQ: channel " + key + " not exists") 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) storeKey, err := combKey(topicName, msgID)
if err != nil { if err != nil {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册