是否有一个好的框架或示例来与 Kafka 流进行多拓扑集成测试

Question

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

例如

topology1 -> topology2 -> topology3

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

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

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

Answer 1

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