[ISSUE #6213] fix: when subscriptionGroupConfig is null ,we do not re…

…gister consumer
apache · Mar 8, 2023 · 61c4ba5 · 61c4ba5
1 parent 98d8988
commit 61c4ba5
Showing 1 changed file with 15 additions and 15 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
@@ -115,21 +115,21 @@ public RemotingCommand heartBeat(ChannelHandlerContext ctx, RemotingCommand requ
                     subscriptionGroupConfig.getRetryQueueNums(),
                     PermName.PERM_WRITE | PermName.PERM_READ, hasOrderTopicSub, topicSysFlag);
             }
-
-            boolean changed = this.brokerController.getConsumerManager().registerConsumer(
-                consumerData.getGroupName(),
-                clientChannelInfo,
-                consumerData.getConsumeType(),
-                consumerData.getMessageModel(),
-                consumerData.getConsumeFromWhere(),
-                consumerData.getSubscriptionDataSet(),
-                isNotifyConsumerIdsChangedEnable
-            );
-
-            if (changed) {
-                LOGGER.info(
-                    "ClientManageProcessor: registerConsumer info changed, SDK address={}, consumerData={}",
-                    RemotingHelper.parseChannelRemoteAddr(ctx.channel()), consumerData.toString());
+            if (null != subscriptionGroupConfig) {
+                boolean changed = this.brokerController.getConsumerManager().registerConsumer(
+                    consumerData.getGroupName(),
+                    clientChannelInfo,
+                    consumerData.getConsumeType(),
+                    consumerData.getMessageModel(),
+                    consumerData.getConsumeFromWhere(),
+                    consumerData.getSubscriptionDataSet(),
+                    isNotifyConsumerIdsChangedEnable
+                );
+                if (changed) {
+                    LOGGER.info(
+                        "ClientManageProcessor: registerConsumer info changed, SDK address={}, consumerData={}",
+                        RemotingHelper.parseChannelRemoteAddr(ctx.channel()), consumerData.toString());
+                }
             }
         }