文件名称:storm-samples:具有不同功能的小型风暴项目
文件大小:9KB
文件格式:ZIP
更新时间:2024-06-12 23:03:33
Java
风暴样本 最简单形式的具有不同功能的小型风暴项目 要求 要测试所有情况,您将需要以下外部实例: 卡夫卡 弹性搜索 可提供样品 测试拓扑 简单的拓扑结构,可从文件中读取行并将“螺栓”添加到每一行的文本中,并将最终结果输出到日志文件中。 mvn exec:java -Dexec.mainClass =“ topology.TestTopology” -Dexec.args =“ src / main / resources / test.txt” TestKafka拓扑 订阅kafka中主题的简单拓扑,并将收到的每条消息输出到日志文件。 mvn exec:java -Dexec.mainClass =“ topology.TestKafkaTopology” TestElasticSearchTopology 简单的拓扑结构,用于从表示json对象的文件中读取行并将这些json对象添加
【文件预览】:
storm-samples-master
----pom.xml(1KB)
----src()
--------main()
----.gitignore(44B)
----README.md(1KB)