Мы создаем управляемые событиями микросервисы с использованием Spring Cloud Stream (с привязкой Kafka) и рассматриваем варианты отслеживания микросервисов, которые не отображаются в качестве конечной точки http. Пожалуйста, предложите.
Я понимаю, что использование Sleuth автоматически добавит идентификатор трассировки и span в журналы, если он превышает http. Документация не ясна для использования с Spring Cloud Stream - https://cloud.spring.io/spring-cloud-sleuth/spring-cloud-sleuth#_messaging
Нашел пример, но не уверен, что это правильный подход - https://github.com/bjedrzejewski/food-order-publisher/blob/zipkin-example/src/main/java/com/e4developer/foodorderpublisher/FoodOrderController.java
Спасибо
Sleuth сделает то же самое для обмена сообщениями, используя заголовки сообщений для распространения идентификатора диапазона, идентификатора трассы и другой соответствующей информации.Это делается путем регистрации специального перехватчика канала.