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