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

is there a good framework or example for integration test of multi topology with kafka streams

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

例如

topology1 -> topology2 -> topology3

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

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

UPDATE: 我通过 through

连接所有拓扑来解决它

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