Merge pull request #214 from xwm1992/1.2.0

[ISSUE #211]Rocketmq-connector throw nullpointer exception
apache · Feb 5, 2021 · e5b4d5a · e5b4d5a
2 parents 60ba2a0 + 1e4e503
commit e5b4d5a
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