Merge pull request #214 from xwm1992/1.2.0

[ISSUE #211]Rocketmq-connector throw nullpointer exception
apache · Feb 5, 2021 · a1ace05 · a1ace05
2 parents 0a5effa + d6fa3e5
commit a1ace05
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/.../java/com/webank/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java b/.../java/com/webank/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
@@ -441,6 +441,7 @@ public synchronized void initClientGroupBroadcastConsumer() throws Exception {
         keyValue.put("isBroadcast", "true");
         keyValue.put("consumerGroup", groupName);
         keyValue.put("proxyIDC", accessConfiguration.proxyIDC);
+        keyValue.put("instanceName", ProxyUtil.buildProxyTcpClientID(sysId, dcn, "SUB", accessConfiguration.proxyCluster));
         broadCastMsgConsumer.init(keyValue);
 //        broadCastMsgConsumer.registerMessageListener(new ProxyMessageListenerConcurrently() {
 //            @Override