Storm是一个分布式实时计算系统。类似于Hadoop如何提供一组用于进行批处理的通用基元，Storm提供了一组用于进行实时计算的通用基元。 Storm很简单，可以与任何编程语言一起使用
我正在使用Kafka喷口构建Storm拓扑。我从JSON格式的Kafka（没有Zookeeper）中消费，Storm应该输出它。如何为JSON数据类型定义适当的架构？ ...
将字段添加到使用StormCrawler（和Elasticsearch）进行爬网的内容中
我已按照以下教程使用Stormcrawler进行内容爬网，然后将其存储在elasticsearch中：https://www.youtube.com/watch?v=KTerugU12TY。但是，我想添加到每个...
Storm状态提供的性能调整文档提供了绝对最佳的性能扩展多个并行拓扑，可以产生比简单扩展工作人员更好的性能。我是...
[我上周开始在OpenClassRooms的Kafka和Storm组织。在实际工作中，尝试执行包含Storm的Java代码的JAR时遇到错误。当...
下面是我的配置文件：storm.zookeeper.servers：-“ 10.13.0.91”-“ 10.13.0.93”-“ 10.13.0.104” nimbus.seeds：[“ 10.13.0.91”，“ 10.13.0.93”，“ 10.13.0.104“] storm.local.dir：” / data1 / ...
是否可以在Windows 10下设置Apache Storm最新版本？
我需要在Windows 10下将Apache Storm安装为单节点群集。我发现的最新说明是：http://ptgoetz.github.io/blog/2013/12/18/running-apache-storm-on- Windows /最新的...
我们的系统接受发布请求，并将json正文发送到kafka主题，并且该主题已配置为拓扑的spout，并且拓扑生成了到kafka主题的输出消息。我如何进行负载测试...
在这个最小的示例中，为什么Trident不调用ack（）或fail（）？
我试图在Trident中创建一个小示例。目的是查看在失败情况下如何重播元组。以下是拓扑定义。Random rand = new Random（）; Config ...
在storm.yaml（版本1.0.0）中，我具有下一个配置：nimbus.host：“％nimbus％”升级版本时，我更改为：nimbus.seeds：[“％nimbus％”]在我的脚本中部署所有拓扑，我...
我正在尝试让一个Kafka使用者同时使用来自Kafka的消息。我遇到的实际问题是消息队列存储在Storm Spout中。我正在尝试...
我有一个喷嘴，它从每秒40K qps的源中读取数据。我有两个螺栓，第一个螺栓从源中读取数据并进行数据库连接以建立一个每小时刷新一次的缓存。 ...
我在本地模式下运行Apache Storm拓扑，它工作正常，但是当我将其提交给Storm时，除了拓扑之外，喷口螺栓不会显示在Storm UI中。建议...
Storm Crawler 1.4或1.5与ES 6.5.0兼容吗？
我正在使用ES 6.5.0，我必须使用什么版本的apache storm，storm crawler和zookeeper兼容版本？
我使用streamparse在构建中具有拓扑结构，它从kafka接收输入，随后spout将消息传输到主螺栓，主螺栓计算并生成10 MB的消息，然后此消息...
我的Apache Storm拓扑越来越慢。我想知道哪种方法消耗最多的时间并降低拓扑速度。我可以剖析Apache Storm拓扑以了解性能在哪里...
我需要将Apache Storm 1.0.0更新到最新版本1.x.x（1.2.3）。需要什么步骤？风暴配置文件有什么变化？有帮助（迁移）的指南吗？谢谢...
假设我有一个由三个服务器组成的风暴集群，分别命名为server1，server2，server3。 Server1作为主节点运行，server2和3作为工作节点运行。当我向Server1提交拓扑时，...
我正在尝试按照1.2.3 v的Apache风暴教程。尝试从Storm Starter运行中获取ExclamationTopology示例。我使用brew在Macbook上安装了Storm。这意味着我...