У меня есть следующая топология функционального стиля:
1) KStream input
2) filter
3) flapMap
4) aggregate
5) filter
6) map
7) KStream output
Входные данные KStream идут с заголовками sleuth, но они теряются в потоке kafka. FlapMap разделил одну запись на N записей. Мне нужно, чтобы каждая выходная запись имела те же заголовки, что и входная запись.
Dependency Versions:
spring-cloud-stream-binder-kafka-streams:3.0.1.RELEASE
spring-cloud-starter-sleuth:2.2.1.RELEASE
Я прочитал официальную документацию и некоторые статьи, такие как https://blog.jdriven.com/2019/10/distributed-tracing-with-kafka-streams/, но мне нужно знать, что такое правильный способ сделать это.
спасибо