From d6fa3e5127f08477959faf687f28b1e4f3edba03 Mon Sep 17 00:00:00 2001 From: xwm1992 Date: Fri, 5 Feb 2021 17:58:17 +0800 Subject: [PATCH] [ISSUE #211]Rocketmq-connector throw nullpointer exception --- .../core/protocol/tcp/client/group/ClientGroupWrapper.java | 1 + 1 file changed, 1 insertion(+) diff --git a/eventmesh-runtime/src/main/java/com/webank/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java b/eventmesh-runtime/src/main/java/com/webank/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java index 45331604b1..2e183dc51e 100644 --- a/eventmesh-runtime/src/main/java/com/webank/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java +++ b/eventmesh-runtime/src/main/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