我有一个系统,我们有 2 个模块。
1) 模块 1 是一个具有多个端点的 webapp,部署在 Tomcat 上。2) 模块 2 是一个可执行的 jar,(不是 web 应用程序),它启动了 2 个 Kafka 消费者(K1 和 K2),分别监听 topic1 和 topic2。
Web 应用程序(模块 1)将消息推送到 topic1。K1 监听topic1。它接收消息,处理它们并将处理后的消息推送到topic2。K2 监听 topic2。消息由 K2 完全处理,不会进一步传播。
此流程中有多个可能发生错误的点。我想使用 Zipkin/ Jaegar 来跟踪整个流程,并将日志链接到 trace id,以便可以轻松快速地调查任何问题。
谁能建议我前进的道路?