Skip to content

Update kafka doc #734

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.

Sign up for GitHub

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

Merged
sharang merged 1 commit into from
Aug 29, 2025
Merged

Update kafka doc #734

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
5 changes: 3 additions & 2 deletions docs/zh/05-features/01-l7-protocols/06-mq.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,9 @@ permalink: /features/l7-protocols/mq
| | request_resource | 请求资源 | $topic-$partition:$offset | $topic-$partition:$offset | 仅 Produce、Fetch 消息，取第一个对应字段 [1][2] |
| | request_id | 请求 ID | correlation_id | correlation_id | 参考：[使用 CorrelationID 关联 Req-Resp 通信场景](https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-CommonRequestandResponseStructure) |
| | endpoint | 端点 | $topic-$partition | $topic-$partition | 仅 Produce、Fetch 消息，取第一个对应字段 |
| Resp. | response_code | 响应码 | -- | error_code | 仅 Produce、Fetch、JoinGroup、LeaveGroup、SyncGroup 消息 |
| Resp. | response_code | 响应码 | -- | error_code | 仅 Produce、Fetch、JoinGroup、LeaveGroup、SyncGroup 消息 [3] |
| | response_status | 响应状态 | -- | error_code | 正常: error_code=0; 服务端异常: error_code!=0 |
| | response_exception | 响应异常 | -- | error_code | error_code 的[英文描述](http://kafka.apache.org/protocol#protocol_error_codes) |
| | response_exception | 响应异常 | -- | error_code | error_code 的[英文描述](http://kafka.apache.org/protocol#protocol_error_codes) [3] |
| | response_result | 响应结果 | -- | -- | -- |
| Trace | trace_id | TraceID | traceparent, sw8 | traceparent, sw8 | 从首个 Record 的对应 Header 字段中提取 |
| | span_id | SpanID | traceparent, sw8 | traceparent, sw8 | 从首个 Record 的对应 Header 字段中提取 |
Expand All @@ -28,6 +28,7 @@ permalink: /features/l7-protocols/mq

- [1] 表中所有 partition 对应 Kafka 协议中的 partition id 或 partition index。
- [2] Produce 的 offset 取自 Response 中的 base_offset，Fetch 的 offset 取自 Request 中的 fetch_offset。
- [3] 目前尚未支持解析的 api key 类型会将 response_code 设置为 -2，response_exception 设置为“Type not yet inspected by DeepFlow”。

**Metrics 字段映射表格，以下表格只包含存在映射关系的字段**

Expand Down
Loading