Skip to content

Commit 190152b

Browse files
committed
bugfix : miss group set
1 parent bb086ec commit 190152b

File tree

1 file changed

+1
-0
lines changed
  • eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common

1 file changed

+1
-0
lines changed

eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ public static UserAgent generateSubClient(UserAgent agent) {
109109
user.setVersion(agent.getVersion());
110110
user.setIdc(agent.getIdc());
111111
user.setConsumerGroup(agent.getConsumerGroup());
112+
user.setProducerGroup(agent.getProducerGroup());
112113
user.setPurpose(EventMeshCommon.USER_AGENT_PURPOSE_SUB);
113114
return user;
114115
}

0 commit comments

Comments
 (0)