milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improve warning message in rocksmq (#11227) 

Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
pull/11296/head
Xiangyu Wang 2021-11-05 10:58:55 +08:00 committed by GitHub
parent 93d869a39e
commit 60848029e1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
View File

@ -185,7 +185,7 @@ func (rmq *rocksmq) Close() {
for _, consumer := range v.([]*Consumer) {
err := rmq.DestroyConsumerGroup(consumer.Topic, consumer.GroupName)
if err != nil {
log.Warn("Rocksmq DestroyConsumerGroup failed!", zap.Any("topic", consumer.Topic), zap.Any("groupName", consumer.GroupName), zap.Any("error", err))
log.Warn("Failed to destroy consumer group in rocksmq!", zap.Any("topic", consumer.Topic), zap.Any("groupName", consumer.GroupName), zap.Any("error", err))
}
topic = consumer.Topic
}