opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #3949] Fix buildHeartbeatData

Browse Source 
* Use topic as producer group
This commit is contained in:
zhouxiang
2022-07-13 11:29:17 +08:00
parent 2da9293575
commit bc7fbfd46f
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/adapter/GrpcConverter.java
+5 -2
View File
@@ -106,17 +106,20 @@ public class GrpcConverter {
ClientSettings clientSettings) {
HeartbeatData heartbeatData = new HeartbeatData();
heartbeatData.setClientID(clientId);
String groupName = wrapResourceWithNamespace(request.getGroup());
switch (clientSettings.getClientType()) {
case PRODUCER: {
Set<org.apache.rocketmq.common.protocol.heartbeat.ProducerData> producerDataSet = new HashSet<>();
producerDataSet.add(buildProducerData(groupName));
for (Resource topic : clientSettings.getSettings().getPublishing().getTopicsList()) {
String topicName = wrapResourceWithNamespace(topic);
producerDataSet.add(buildProducerData(topicName));
}
heartbeatData.setProducerDataSet(producerDataSet);
break;
}
case PULL_CONSUMER:
case PUSH_CONSUMER:
case SIMPLE_CONSUMER: {
String groupName = wrapResourceWithNamespace(request.getGroup());
Set<org.apache.rocketmq.common.protocol.heartbeat.ConsumerData> consumerDataSet = new HashSet<>();
consumerDataSet.add(buildConsumerData(groupName, clientSettings));
heartbeatData.setConsumerDataSet(consumerDataSet);