alibaba / alibaba/spring-cloud-alibaba

About Aliyun RocketMQ CustomizedTraceTopic

Open
#916 7 comments 0 reactions 1 assignee Claimed by @zkzlx View on GitHub
area/rocketmq
Dominant language
Java
Stars
29.2k
Forks
8.5k
Avg merge
1d 23h
Merged PRs (30d)
12

Description

**Which Component**
eg. Nacos Discovery, Sentinel
RocketMQ

**Describe what problem you have encountered**
A clear and concise description of what you want to do.
当我在同一个项目A同时使用生产者A和消费者B的时候,项目B使用一个生产者B,明明已经消费成功,阿里云的控制台上消费轨迹却显示尚未消费。
但是只在项目A只保留消费者B,项目B保留生产者B的时候,阿里云上的消费轨迹可以看到消费成功。
[我已经查看过](https://github.com/alibaba/spring-cloud-alibaba/issues/764)该问题,可以保证customizedTraceTopic是正确的,下面贴出我项目A和项目B的配置。
项目A:
spring.cloud.stream.rocketmq.binder.name-server=127.0.0.1:9876
spring.cloud.stream.rocketmq.binder.access-key=YourAccessKey
spring.cloud.stream.rocketmq.binder.secret-key=YourSecretKey
spring.cloud.stream.rocketmq.binder.name-server=NameServerInMQ
spring.cloud.stream.rocketmq.binder.customized-trace-topic=rmq_sys_TRACE_DATA_cn-qingdao-publictest

#生产者A
spring.cloud.stream.bindings.output.destination=test-topic1
spring.cloud.stream.bindings.output.content-type=application/json
spring.cloud.stream.rocketmq.bindings.output.producer.group=test-group1
#消费者B
spring.cloud.stream.bindings.input1.destination=test-topic2
spring.cloud.stream.bindings.input1.content-type=application/json
spring.cloud.stream.bindings.input1.group=test-group2

项目B:
#生产者B
spring.cloud.stream.rocketmq.binder.name-server=127.0.0.1:9876
spring.cloud.stream.rocketmq.binder.access-key=YourAccessKey
spring.cloud.stream.rocketmq.binder.secret-key=YourSecretKey
spring.cloud.stream.rocketmq.binder.name-server=NameServerInMQ
spring.cloud.stream.rocketmq.binder.customized-trace-topic=rmq_sys_TRACE_DATA_cn-qingdao-publictest

spring.cloud.stream.bindings.output1.destination=test-topic2
spring.cloud.stream.bindings.output1.content-type=application/json
spring.cloud.stream.rocketmq.bindings.output1.producer.group=test-group2

请问我该如何解决这个问题,可以在同一个项目中同时使用生产者和消费者,并且可以追踪到阿里云的消息轨迹。
**Describe what information you have read**
eg. I have read the reference doc of Sentinel
我已经看过相关文档 https://github.com/alibaba/spring-cloud-alibaba/wiki/RocketMQ#%E9%98%BF%E9%87%8C%E4%BA%91-mq-%E6%9C%8D%E5%8A%A1

**Which Component**
eg. Nacos Discovery, Sentinel
RocketMQ

**Describe what problem you have encountered**
A clear and concise description of what you want to do.
When I use both Producer A and Consumer B in the same project A, Producer B is used in Project B. It is clear that the consumption has been successful, but the consumption trajectory on Aliyun's console shows that it has not been consumed yet.

But only when item A only retains consumer B and item B retains producer B, the consumption trajectory on Aliyun can see the success of consumption.

[I've looked at it] (https://github.com/alibaba/spring-cloud-alibaba/issues/764) This question can ensure that customized TraceTopic is correct. The configuration of my project A and project 2 is posted below.
----------------------------------------------------------------------------------------------------------
project A:
spring.cloud.stream.rocketmq.binder.name-server=127.0.0.1:9876
spring.cloud.stream.rocketmq.binder.access-key=YourAccessKey
spring.cloud.stream.rocketmq.binder.secret-key=YourSecretKey
spring.cloud.stream.rocketmq.binder.name-server=NameServerInMQ
spring.cloud.stream.rocketmq.binder.customized-trace-topic=rmq_sys_TRACE_DATA_cn-qingdao-publictest

spring.cloud.stream.bindings.output.destination=test-topic1
spring.cloud.stream.bindings.output.content-type=application/json
spring.cloud.stream.rocketmq.bindings.output.producer.group=test-group1
spring.cloud.stream.bindings.input1.destination=test-topic2
spring.cloud.stream.bindings.input1.content-type=application/json
spring.cloud.stream.bindings.input1.group=test-group2

project B:
spring.cloud.stream.rocketmq.binder.name-server=127.0.0.1:9876
spring.cloud.stream.rocketmq.binder.access-key=YourAccessKey
spring.cloud.stream.rocketmq.binder.secret-key=YourSecretKey
spring.cloud.stream.rocketmq.binder.name-server=NameServerInMQ
spring.cloud.stream.rocketmq.binder.customized-trace-topic=rmq_sys_TRACE_DATA_cn-qingdao-publictest

spring.cloud.stream.bindings.output1.destination=test-topic2
spring.cloud.stream.bindings.output1.content-type=application/json
spring.cloud.stream.rocketmq.bindings.output1.producer.group=test-group2
----------------------------------------------------------------------------------------------------------
How can I solve this problem? I can use both producers and consumers in the same project, and track Aliyun's message trajectory.
**Describe what information you have read**
eg. I have read the reference doc of Sentinel
I've seen the relevant ### ### documents.
https://github.com/alibaba/spring-cloud-alibaba/wiki/RocketMQ#%E9%98%BF%E9%87%8C%E4%BA%91-mq-%E6%9C%8D%E5%8A%A1

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.