AWS XRay服务地图组件断开，OpenTelemetry Kafka链路配置问题排查

核心原因 #

AWS XRay生成服务地图依赖三个核心条件：上下游Span的父子关系正确、链路中间件（这里是Kafka）的Span属性符合XRay识别规范、Collector导出配置支持messaging类属性解析。你目前Trace ID匹配说明上下文注入正常，缺失的是规范属性和导出配置。

修复步骤 #

1. 补全Node.js Kafka生产侧Span属性 #

你当前的Kafka生产Span缺少XRay识别消息中间件节点的必填属性，需要修改KafkaJsInstrumentation配置，补充以下字段：

• messaging.operation 固定值为 send，标识是生产消息操作
• net.peer.name 填写Kafka集群的访问地址
• messaging.kafka.bootstrap.servers 填写Kafka broker地址列表

最新版本的opentelemetry-instrumentation-kafkajs会自动生成上述属性，可优先升级组件版本，也可以通过 instrumentation 的请求钩子手动注入属性。

另外注意你当前tracer.js中OTLP导出的默认端口为55680，和你Collector配置的4317端口不匹配，要么修改默认端口为http://localhost:4317，要么配置OTEL_EXPORTER_OTLP_ENDPOINT环境变量和Collector端口保持一致。

2. 补充Java消费侧的Kafka埋点配置 #

在Java启动脚本中新增两个环境变量，确保Kafka埋点生成符合规范的消费Span：

export OTEL_INSTRUMENTATION_KAFKA_ENABLED=true
export OTEL_INSTRUMENTATION_COMMON_MESSAGING_EXPERIMENTAL_SPAN_ATTRIBUTES_ENABLED=true

配置后Java侧生成的消费Span会自动添加messaging.operation=process、Span Kind为CONSUMER的属性，XRay可以识别为消息消费操作，和上游生产Span、Kafka节点建立关联。

3. 修改OTel Collector的AWS XRay导出配置 #

在Collector的awsxray导出器配置中开启全属性索引，确保XRay可以识别messaging类字段：

exporters:
  awsxray:
    region: 'eu-central-1'
    max_retries: 10
    index_all_attributes: true

配置完成后重启所有组件，等待1-2分钟后新上报的链路就会生成正确的服务地图，链路结构为：nodejs-producer -> input-topic（Kafka节点） -> otlp-consumer-producer -> final-topic（Kafka节点）。

内容的提问来源于stack exchange，提问作者Majid Azimi