storm保证数据可靠性如何代码实现？
前提是已经知道了apache-storm的3种数据处理级别：1.至多一次2.至少一次3.恰好一次storm默认是使用第一种处理级别。我希望做的是第三种（因为对所需数…
Storm中可不可以使用Websocket发送消息
我在Storm Bolt处理完数据后，想通过Websocket实时发送给前端进行显示处理，可以始终都发送不出去，其他地方发送都可以发送成功，数据可以传递给Webso…
storm trident 分支问题
想咨询一个storm trident分支的问题，如图： 得到数据 判断数据如果数据为true 就执行1，数据为false就执行2 能否做到呢？ ### 问题描述 …
【Windows】【Storm】KILL Topology时，supervisor异常退出
在kill topology的时候，windows上的supervisor无法停止worker，然后supervisor自己停止了，如图： …
storm 提交Topologies出错
问题 通过maven构建的storm应用在ide中运行正常，打包后提交本地storm服务出错 当pom的scop配置provided 时候， 打包提交后storm报错是 Found multip…
storm.yaml中配置zookeeper集群,zookeeper的端口问题
我的zk是用的docker，zookeeper的服务端口不一样,分别是2181 2182 2183 请问该怎么配置storm.yaml…
storm实时流处理中如何利用redis去除重复数据？
1.storm处理上网行为日志数据(单条日志时间戳很接近)，同一用户30天内不重复发送消息，我使用redis去重，由于storm高并发的机制，当我设置redis bolt…
运行storm word count 提示找不到clojure.lang.ILookup的类文件
<dependency> <groupId>storm</groupId> <artifactId>storm</artifactId> <version>0.6.0</version> </dependency>…
Storm1.1.0+kafka0.10.2.1:NoSuchMethodError
本人刚刚开始使用storm和kafka,现想运行一个github上的开源项目:github:cestella/streaming_outliers 但是因为这个程序是用storm0.10版本写的,而我的…
storm的BaseBasicBolt什么时候会自动重启？
我的Kafka在客户端每次上线都会有日志，我看我的一个storm程序中使用了producer，而且这个程序我就启动了一次然后一直跑，如果没有问题的话，日志中…
