From 8860bf61d42e075989d723e589a59c31a5b3f792 Mon Sep 17 00:00:00 2001 From: kashvi0 Date: Tue, 9 Apr 2024 22:34:59 +0530 Subject: [PATCH] Issue #3763 Removed unused value of consumerGroup --- plugin/connector/rocketmq/client/rocketmq_consumer.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/plugin/connector/rocketmq/client/rocketmq_consumer.go b/plugin/connector/rocketmq/client/rocketmq_consumer.go index 2cc867b..f525b46 100644 --- a/plugin/connector/rocketmq/client/rocketmq_consumer.go +++ b/plugin/connector/rocketmq/client/rocketmq_consumer.go @@ -19,12 +19,13 @@ import ( "context" "errors" "fmt" + "strconv" + "strings" + "github.com/apache/incubator-eventmesh/eventmesh-server-go/plugin/connector/rocketmq/constants" "github.com/apache/rocketmq-client-go/v2" "github.com/apache/rocketmq-client-go/v2/consumer" "github.com/apache/rocketmq-client-go/v2/primitive" - "strconv" - "strings" ) type SubscribeFunc func(context.Context, ...*primitive.MessageExt) (consumer.ConsumeResult, error) @@ -144,7 +145,7 @@ func (r *RocketMQConsumerWrapper) getConsumerOptionsFromProperties(properties ma } consumerGroup := clientConfig.ConsumerGroup if isBroadCasting { - consumerGroup = fmt.Sprintf("%s-%s", constants.ConsumerGroupBroadcastPrefix, consumerGroup) + _ = fmt.Sprintf("%s-%s", constants.ConsumerGroupBroadcastPrefix, consumerGroup) } options = append(options, consumer.WithGroupName(clientConfig.ConsumerGroup))