java - 有没有一个好的框架或示例用于多拓扑与kafka流的集成测试

Question

我完成了一个具有多拓扑的应用程序，这些拓扑通过其源和接收器相互链接。

例如

topology1 -> topology2 -> topology3

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

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

更新:我通过通过 through

连接所有拓扑来解决这个问题

Answer 1

更新:我通过通过连接所有拓扑来解决它。