用Storm搭设了个平台，通过KafkaSpout从kafka读取消息，但现在遇到如下问题： 1. 如果kafka消息层的消息产生速度保持在每分钟 2 ...

caiyifeng 2015-7-27 7 13575

我调用的是kafkaSpout 从kafka取消息，请问能否得到 每秒从kafka获取的消息数量，我知道storm有个registerMetric，CountMetric() ...

caiyifeng 2015-7-22 5 13302

我的Strom是集群环境一共3台机器，一个主节点2个子节点。 然后我做了一个最简单的strom例子。 SimpleSpout，获取数据，数据就 ...

lwb314 2015-7-27 7 10810

storm0.9.5 刚研究storm不久，问些幼稚问题，大家别见笑，看资料得知三者关系如下图 测试结果与个文档中提到的计算关系数量 ...

evababy 2015-7-23 3 22483

我发布到storm上的topology运行良好，但奇怪的时候，我第二天过来，总是发现整个stormshutdown 我查看了nimbus.log,superviso ...

caiyifeng 2015-4-23 10 100198

我程序中 spout用的是storm.kafka.KafkaSpout。 然而在运行一段时间后看ui会有失败的 有没有人遇见过这个情况啊讨论下啊 ...

mjjian0 2015-7-14 1 11031

我编写了一个Spout.java 类，它需要从第三方工具包中调用工具类中的方法来完成 nextTuple()，那么 请问我打包jar文件时，需要将 ...

hapjin 2015-7-10 1 37051

需求：有一个项目类似QQ发送消息的，可以单发，群发。客户希望能实时看到消息发送量的折线图（按小时为单位）。目前数据存入的是 ...

尘世随缘 2015-3-30 14 83826

在群里有个哥们用了storm epl，他发给了我个demo，我也看了，感觉要用的话还要学他的sql。但学了也不知道能在项目中用吗？ 所 ...

mjjian0 2015-7-7 3 16479

本地也映射了 hostname ip 也能ping通地址，但就是访问不到日志链接 查看 启动logviewer 的日志发现： 2015-06-30 17 ...

mjjian0 2015-7-1 2 45537

ip hostname 也在本地映射了 也能 ping通 IP地址 查看进程日志发现

mjjian0 2015-7-1 7 75879

storm 每秒消费kafka的数据 大概极限是多少条？

Alkaloid0515 2015-6-30 1 14741

java.nio.channels.UnresolvedAddressException: null at sun.nio.ch.Net.checkAddress(Net.java:30) ~[na:1.6.0_25] ...

bob007 2015-6-13 1 33015

如图：在SpoutEmitter报了类不能转换的错误2015-06-02T09:31:35.083+0800 b.s.d.executor [ERROR] java.lang.RuntimeException ...

allenyoung25 2015-6-2 1 24350

我在eclipse中运行了本地模式，却报错，错误如下： LocalCluster cluster = new LocalCluster(); cluster.sub ...

caiyifeng 2015-5-21 2 30108

在生产环境如何建立一个合适的storm集群，比如说，我需要给nimbus、supervisor、worker分配多少内存，启用多少个supervisor？我 ...

hahaxixi 2015-5-12 2 12811

请教些问题： 本人现在在着手写实时计算方面的论文，现在思路还是有点乱， （1） 关于实时计算有哪些算法可以去研究下； ...

sunshine_junge 2014-10-27 5 14214

想写个简单的Storm处理滑动窗口求和的程序，但是无奈遇到问题，还请各位大神不吝赐教。 现有数据存放在某个文件中，内容如下： ...

梦回三国 2014-10-16 16 38263

autoconf版本是2.68，automake1.11，libtool版本是2.4.2

allenyoung25 2015-5-4 4 24735

我在对一些数据做统计，用到redies，把统计结果放在redies中，然后下一个tuple来了从redies中取出来然后在做统计，统计后在放到r ...

mjjian0 2015-4-25 3 19946

刚才发了帖子咨询storm总是会莫名shutdown 刚才发现kafka也是，白天都正常运行，第二天过来看，总是会shutdown 我查了日志信 ...

caiyifeng 2015-4-23 5 36325

1. 我在PC服务器上装了3台虚拟机，配置了3个storm集群节点，配置storm.yaml ，slot配置了10个端口 26700------26709 2. 我发布 ...

caiyifeng 2015-4-20 3 11193

比如我现在的实时项目架构是：flume--》kafka---》storm---》hive 最后通过storm分析，分析后的数据落地到hive，但现在有个问题 ...

mjjian0 2015-4-20 1 15095

比如说我的数据是这样的name age sex a 23 男 b 22 女 c 22 ...

mjjian0 2015-4-14 2 11588

如题，在安装storm集群的时候，一般都需要安装zeromq和Jzmq，但是kafka和zeromq的作用看起来差不多，都是用来做mq传输用的，那么 ...

yepiaochen 2015-4-18 2 52560

有没有关于Storm UI界面参数字段 的说明？

rsgg03 2015-4-16 1 20880

emit是应该弹送到下个bolt中,那么作为最后的bolt是否还需要emit? 看了一些书的例子,有些有,有些没有. 自己试验了一下,感觉没 ...

qyd100 2015-4-15 1 26066

六台flume服务器，三台kafka服务器，大概流程是这样：flume采集数据到kafka，然后storm去kafka数据分析，为了做交易耗时统计，采 ...

mjjian0 2015-4-12 7 16515