Kafka
You are viewing the English version of this page because it has not yet been fully translated. Interested in helping out? See Contributing.
This is used as a message queue service to connect the checkout service with the accounting and fraud detection services.
Configuration
| Variable | Default | Description |
|---|---|---|
KAFKA_TOPIC | orders | Topic that checkout produces order messages to, and that accounting and fraud detection consume from. |
All three services read the same variable, so change it in .env (or
.env.override) rather than on an individual service, otherwise the producer
and consumers end up on different topics.
Auto-instrumentation
This service relies on the OpenTelemetry Java agent and the built in JMX Metric Insight Module to capture Kafka broker metrics and send them off to the collector via OTLP.
The agent is passed into the process using the -javaagent command line
argument. Command line arguments are added through the KAFKA_OPTS in the
Dockerfile.
ENV KAFKA_OPTS="-javaagent:/tmp/opentelemetry-javaagent.jar -Dotel.jmx.target.system=kafka-broker"
意见反馈
这个页面对您有帮助吗？
Thank you. Your feedback is appreciated!
Please let us know how we can improve this page. Your feedback is appreciated!