We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bb086ec commit 190152bCopy full SHA for 190152b
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java
@@ -109,6 +109,7 @@ public static UserAgent generateSubClient(UserAgent agent) {
109
user.setVersion(agent.getVersion());
110
user.setIdc(agent.getIdc());
111
user.setConsumerGroup(agent.getConsumerGroup());
112
+ user.setProducerGroup(agent.getProducerGroup());
113
user.setPurpose(EventMeshCommon.USER_AGENT_PURPOSE_SUB);
114
return user;
115
}
0 commit comments