[ISSUE #211]Rocketmq-connector throw nullpointer exception

apache · Feb 5, 2021 · d6fa3e5 · d6fa3e5
1 parent 3feb02e
commit d6fa3e5
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