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