Kafka
Ви переглядаєте англійську версію сторінки, тому що її ще не було повністю перекладеною українською. Бажаєте допомогти? Дивіться як взяти Участь.
PS. Неофіційний український переклад (не перевірений і не ухвалений OpenTelemetry) доступний на сайті члена спільноти, створеному на основі PR #5891. Ми надаємо це посилання як тимчасовий захід підтримки українських читачів та потенційних учасників, доки не буде готовий офіційний переклад.
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!