是否有使用 kafka 流进行多拓扑集成测试的好的框架或示例

Question

我完成了一个多拓扑的应用程序，这些拓扑通过它们的源和接收器相互连接。

例如

topology1 -> topology2 -> topology3

使用'kafka-streams-test-utils'，每个拓扑的单元测试都很容易，但我不知道如何处理集成测试。

是否有针对所有拓扑进行集成测试的框架或示例？

UPDATE: 我通过连接所有拓扑来解决它 through

Answer 1

更新：我通过直通连接所有拓扑解决了这个问题。