Kafka
Kafka використовується як служба черги повідомлень для зʼєднання служби оформлення замовлень зі службами бухгалтерського обліку та виявлення шахрайства.
Конфігурація
| Змінна | Стандартно | Опис |
|---|---|---|
KAFKA_TOPIC | orders | Тема, у яку служба оформлення замовлень надсилає повідомлення про замовлення, і з якої служби бухгалтерського обліку та виявлення шахрайства споживають повідомлення. |
Усі три служби читають ту саму змінну, тому змінюйте її у .env (або .env.override), а не в окремій службі, інакше виробник і споживачі опиняться на різних темах.
Автоінструментування
Ця служба покладається на агент OpenTelemetry Java та вбудований Модуль JMX Metric Insight для збору метрик брокера Kafka та відправлення їх до колектора через OTLP.
Агент передається в процес за допомогою аргументу командного рядка -javaagent. Аргументи командного рядка додаються через KAFKA_OPTS у Dockerfile.
ENV KAFKA_OPTS="-javaagent:/tmp/opentelemetry-javaagent.jar -Dotel.jmx.target.system=kafka-broker"
Зворотний зв’язок
Чи була ця сторінка корисною?
Дякуємо. Ми цінуємо ваші відгуки!
Будь ласка, дайте нам знати як ми можемо покращити цю сторінку. Ми цінуємо ваші відгуки!