我有一个系统，我们有两个模块。
1） 模块1是一个部署在tomcat上的具有多个端点的webapp。2） 模块2是一个可执行的jar（不是一个web应用程序），它使两个kafka消费者（k1和k2）分别收听topic1和topic2。
网络应用程序（模块1）将消息推送到主题1。k1侦听topic1。它接收消息，对其进行处理，并将处理后的消息推送到topic2。k2听topic2。消息由k2完全处理，不会进一步传播。
此流中可能会出现多个错误点。我想使用zipkin/jaegar来跟踪整个流，还可以将日志链接到跟踪id，这样就可以方便快捷地调查任何问题。
谁能告诉我前进的方向吗？