为 Apache Storm 编写集成测试

Question

在 Java 中为 Apache Storm 拓扑编写集成测试的推荐方法是什么？感谢任何建议/链接。

Answer 1

您可能想要使用的工具是FeederSpout和FixedTupleSpout。所有 spout 都实现该CompletableSpout接口的拓扑可以使用类中的工具运行直至完成Testing。Storm 测试还可以选择“模拟时间”，这意味着 Storm 拓扑将空闲，直到您调用LocalCluster.advanceClusterTime. 例如，这可以让您在 Bolt 发出之间进行断言。