Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

#28 补充消息轨迹文档 #29

Merged
merged 3 commits into from
Oct 29, 2021
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,8 @@
* [消费模型](/rocketmq/introduction/features/consume_model)
* [消息回溯](/rocketmq/introduction/features/message_backtracking)
* [死信队列](/rocketmq/introduction/features/dlq)
* [消息轨迹](/rocketmq/introduction/features/msessage_trace.md)
* [网络模式](/rocketmq/introduction/features/net)
* [产品优势](/rocketmq/introduction/advantages)
* 操作指南
* 实例管理
Expand All @@ -28,6 +30,7 @@
* [重置消息位](/rocketmq/guide/group/reset_offset)
* [Group删除](/rocketmq/guide/group/delete)
* [消息查询](/rocketmq/guide/message)
* [消息轨迹](/rocketmq/guide/message_trace)
* [死信队列](/rocketmq/guide/dlq)
* [操作日志](/rocketmq/guide/log)
* 告警通知
Expand Down
2 changes: 2 additions & 0 deletions _sidebar.md
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
* [消费模型](/rocketmq/introduction/features/consume_model)
* [消息回溯](/rocketmq/introduction/features/message_backtracking)
* [死信队列](/rocketmq/introduction/features/dlq)
* [消息轨迹](/rocketmq/introduction/features/msessage_trace.md)
* [网络模式](/rocketmq/introduction/features/net)
* [产品优势](/rocketmq/introduction/advantages)
* 操作指南
Expand All @@ -27,6 +28,7 @@
* [重置消息位](/rocketmq/guide/group/reset_offset)
* [Group删除](/rocketmq/guide/group/delete)
* [消息查询](/rocketmq/guide/message)
* [消息轨迹](/rocketmq/guide/message_trace)
* [死信队列](/rocketmq/guide/dlq)
* [操作日志](/rocketmq/guide/log)
* 告警通知
Expand Down
9 changes: 9 additions & 0 deletions guide/message_trace.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
# 消息轨迹

目前支持按照MessageId查询消息轨迹,可在消息查询页面查询消息之后,选择指定消息点击“消息轨迹”按钮查询消息轨迹信息。

![msg_trace_01](/rocketmq/images/msg_trace_01.png)

可点击切换消费组查看不同消费组消费轨迹信息

![msg_trace_02](/rocketmq/images/msg_trace_02.png)
Binary file added images/msg_trace_01.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added images/msg_trace_02.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
21 changes: 21 additions & 0 deletions introduction/features/msessage_trace.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
# 消息轨迹

消息轨迹是指一条消息从生产到被消费经过所有节点的链路信息,包括生产与消费轨迹信息,用户可根据消息轨迹获取消息相关链路信息进行相关的业务分析。

## 基本信息

基本消息指消息自身消息,包括所属Topic、Key、Tag、消费状态等信息;

## 生产信息

包括生产者地址、消息发送时间、消息发送耗时、消息发送状态等信息;

## 消费信息

单条消息可能被多个消费组的多个消费者消费,消费消息包括每个消费该条消息消费者的客户端地址、消费状态、消费耗时及投递时间等信息;

## 接入方式

客户端需要设置消息轨迹才可使用消息轨迹功能。

[JAVA版本客户端设置消息轨迹示例](https://github.com/apache/rocketmq/tree/rocketmq-all-4.7.1/example/src/main/java/org/apache/rocketmq/example/tracemessage)