Kafka

这是一个用于连接结账服务与会计和欺诈检测服务的消息队列服务。

Kafka服务源代码

自动仪表化

该服务依赖于OpenTelemetry Java代理和内置的JMX度量洞察模块， 以捕获Kafka代理度量指标， 并通过OTLP将它们发送到收集器。

代理通过使用-javaagent命令行参数传递给进程。 命令行参数通过Dockerfile中的KAFKA_OPTS添加。

ENV KAFKA_OPTS="-javaagent:/tmp/opentelemetry-javaagent.jar -Dotel.jmx.target.system=kafka-broker"