From 60848029e1f1202cd5eb796b06f53a5aaee4e209 Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Fri, 5 Nov 2021 10:58:55 +0800 Subject: [PATCH] Improve warning message in rocksmq (#11227) Signed-off-by: Xiangyu Wang --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index d252faba47..ac4829a64e 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -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 }