Kafka

Kafka використовується як служба черги повідомлень для зʼєднання служби оформлення замовлень зі службами бухгалтерського обліку та виявлення шахрайства.

Сирці служби Kafka

Автоінструментування

Ця служба покладається на агент 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"