测试 Storm bolt

标签 testing apache-storm

我是 apache storm 的新手,我一直在寻找无需实际构建完整拓扑即可测试 bolt 的方法。只是想避免模拟测试。相反,我尝试调用 bolt 的方法来发出 OutputCollector 对象中的输出。但是我试图找到一种方法来从 OutputCollector 对象获取数据,但没有找到这样的方法。有什么方法可以简单地访问 OutputCollector 对象中发出的值?

最佳答案

测试 bolt 逻辑的一种方法是编写 FakeDataGeneratorSpout 它模仿拓扑的实际来源。构建测试主拓扑构建器类,可以使用 FakeDataGeneratorSpout 进行测试。

其次,您可以将 bolt 逻辑保留在简单的 Java 类中并为它们编写 junit,然后稍后从实际的 bolt 中调用该测试方法。

关于测试 Storm bolt ,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28338642/

相关文章:

java - Storm-Kafka多个spout,如何分担负载?

android - 错误 : Could not get the Java version. 是否安装了 Java?

unit-testing - 为 SOAP 服务编写 JUnit 测试的最佳方式

asp.net-mvc - asp.net mvc 用户负载测试

testing - 基于现有立方体数据(但更大)创建测试立方体

apache-storm - Storm - 如何检查拓扑是否空闲或正在运行?

ASP.NET session 超时测试

Docker Storm 集群示例

apache-storm - Storm 主管和 worker 未启动

java - Storm 中具有计数和持续时间的翻滚窗口