У меня есть система, где у нас есть 2 модуля.
1) Модуль 1 — это веб-приложение с несколькими конечными точками, развернутое на Tomcat. 2) Модуль 2 представляет собой исполняемый файл jar (не веб-приложение), который запускает 2 потребителей Kafka (K1 и K2), прослушивающих тему 1 и тему 2 соответственно.
Веб-приложение (модуль 1) отправляет сообщения в тему 1. K1 слушает тему 1. Он получает сообщения, обрабатывает их и отправляет обработанные сообщения в тему 2. К2 слушает тему2. Сообщения полностью обрабатываются К2 и дальше не распространяются.
В этом потоке есть несколько точек, где могут возникнуть ошибки. Я хотел использовать Zipkin/Jaegar для отслеживания всего потока, а также связать журналы с идентификатором трассировки, чтобы можно было легко и быстро исследовать любую проблему.
Может ли кто-нибудь предложить мне путь вперед?
