From 736a2cc35873db3daa0f607975e3e6e38283b886 Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Tue, 19 Oct 2021 17:54:37 +0800 Subject: [PATCH] [skip ci]Improve error message in rocksmq (#10196) Signed-off-by: Xiangyu Wang --- internal/util/rocksmq/client/rocksmq/client_impl.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/util/rocksmq/client/rocksmq/client_impl.go b/internal/util/rocksmq/client/rocksmq/client_impl.go index 27885f8af6..3386aba9b4 100644 --- a/internal/util/rocksmq/client/rocksmq/client_impl.go +++ b/internal/util/rocksmq/client/rocksmq/client_impl.go @@ -133,7 +133,7 @@ func (c *client) consume(consumer *consumer) { case _, ok := <-consumer.MsgMutex(): if !ok { // consumer MsgMutex closed, goroutine exit - log.Debug("consumer MsgMutex closed") + log.Debug("Consumer MsgMutex closed") return }