Storm是一个分布式实时计算系统。类似于Hadoop如何提供一组用于进行批处理的通用基元，Storm提供了一组用于进行实时计算的通用基元。 Storm很简单，可以与任何编程语言一起使用
如何使用storm的New Metrics Reporting API？
我使用风暴V1.2.1。根据官方文档设置后，我想在spout中获得一些指标，spout代码如下，但是没有预期的指标数据...
在遵循storm-starter repo中的指南时，我无法实际运行任何拓扑 - 如ExclamationTopology。 mvn clean install -DskipTests = true成功运行，从顶部执行...
两者有什么区别？据我所知，它们都基于有向无环图（DAG）和Storm流程数据的概念实时和Airflow相当移动......
使用自定义IScheduler时如何从远程Storm工作者向Graphite服务器发出指标？
我正在从Apache Storm到Graphite很好地收集指标。然后我开发了一个实现IScheduler接口的自定义调度程序，现在我无法收集任何指标。这是我的 ...
如何将Apache Storm中的延迟指标发送到Graphite服务器？
我已将Apache Storm配置为使用版本2向Graphite服务器发送指标。它正在发送我所有螺栓和喷口的计数参数。我想发送...之间的延迟
我使用[codahale-metrics]获取Storm的螺栓和喷口的指标并发送到Graphite服务器。如何获得在螺栓和喷口之间发送消息的时间？例如。这段代码是......
我使用Kafka作为源构建了一个使用Storm的示例拓扑。这是一个我需要解决方案的问题。每次我杀死拓扑并再次启动它，拓扑开始从......处理
当Storm作业提交给Hadoop集群以使用hdfsbolt写入hdfs时，Storm UI中不会创建任何拓扑。显示错误是因为代码中使用了一些包（org.apache.storm ....
使用elasticsearch-hadoop库从storm到elasticsearch索引元组不起作用
我想将文档索引到Storm中的Elasticsearch，但我无法将任何文档编入索引到Elasticsearch。在我的拓扑结构中，我有一个像这样发出json的KafkaSpout {“tweetId”：...
我在Apache Storm中修改了现有的Even Scheduler代码。以后如何在基准程序上编译和执行此调度程序，并检查指标是否有任何变化？什么配置文件......
Storm可以选择使用setMemoryLoad函数配置每个组件的内存大小（bolt / spout）。工作进程如何对每个执行程序/任务强制执行此约束，因为它们都是......
如何从Combiner / Reducer / Aggregator函数返回包含多个字段的元组？
Storm文档声明：CombinerAggregator返回一个单个元组作为输出。如何从Combiner函数返回包含多个字段的元组？我是 ...
我是apache storm和kafka的新手，作为POC的一部分，我正在尝试使用Kafka和apache storm来处理消息流。我正在使用来自https：//github.com/apache/storm/tree/master /的storm-kafka源代码。
将数据从R bolt发送到下一个bolt时，java.lang.String无法转换为java.util.List错误
我正在使用R bolt处理我的数据。我想将处理过的数据从R bolt发送到我的下一个bolt，即CountBolt.But从R bolt发出时，java.lang.String不能转换为java.util ....
在streamparse.Streamparse中配置远程集群有点困惑在localhost中工作正常。但是不能如何设置集群，我的config.json是：{“library”：“”，“topology_specs”：“...
我正在尝试使用dockerhub映像启动一个包含所有apache风暴部分的容器。使用默认配置，没有拓扑工作正常。 Docker正在运行Ubuntu服务器18的VM上运行....
storm-kafka-client：1.2.2使用Yaml的KafkaSpoutConfig
我试图通过YAML配置KafkaSpout并且我在线程“main”中得到以下错误异常java.lang.IllegalArgumentException：参数类型不匹配下面是我的...
我试图在元组处理超时的情况下理解拓扑的状态（不是在三叉戟模式下）让我们假设在处理某个螺栓中的元组期间，超时阈值是......