From 88a2b2b07c9670f809daaf030d0afe2b7bd32622 Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Tue, 19 Oct 2021 17:52:42 +0800 Subject: [PATCH] [skip ci]Improve error message in rocksmq (#10195) Signed-off-by: Xiangyu Wang --- internal/util/rocksmq/client/rocksmq/client_impl.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/util/rocksmq/client/rocksmq/client_impl.go b/internal/util/rocksmq/client/rocksmq/client_impl.go index 3e0747b8df..27885f8af6 100644 --- a/internal/util/rocksmq/client/rocksmq/client_impl.go +++ b/internal/util/rocksmq/client/rocksmq/client_impl.go @@ -57,7 +57,7 @@ func (c *client) CreateProducer(options ProducerOptions) (Producer, error) { } if reflect.ValueOf(c.server).IsNil() { - return nil, newError(0, "rmq server is nil") + return nil, newError(0, "Rmq server is nil") } // Create a topic in rocksmq, ignore if topic exists err = c.server.CreateTopic(options.Topic) @@ -72,7 +72,7 @@ func (c *client) CreateProducer(options ProducerOptions) (Producer, error) { func (c *client) Subscribe(options ConsumerOptions) (Consumer, error) { // Create a consumer if reflect.ValueOf(c.server).IsNil() { - return nil, newError(0, "rmq server is nil") + return nil, newError(0, "Rmq server is nil") } if exist, con := c.server.ExistConsumerGroup(options.Topic, options.SubscriptionName); exist { log.Debug("ConsumerGroup already existed", zap.Any("topic", options.Topic), zap.Any("SubscriptionName", options.SubscriptionName))