最初的错误：DynamicBrokersReader[ERROR]Node/brokers/ids/0doesnotexist设置：BrokerHostsbrokerHosts=newZkHosts(zks,"/kafka/brokers");然后就是如下错误：2016-04-13T15:07:10.657+0800b.s.util[ERROR]Asyncloopdied!
java.lang.RuntimeException:java.lang.RuntimeExcept..
分类：
其他好文 时间：
2016-04-13 21:05:07
阅读次数：
1186
Java IO/NIO JVM原理与配置、调优 Socket 网络套接字技术 Java Collection java Reflection 多线程与并发编程 设计模式 Collection深入 流式计算原理及应用场景 Storm Kafka Redis 实战案例 离线计算原理及应用场景 Hadoo ...
分类：
其他好文 时间：
2016-04-11 22:12:45
阅读次数：
242
1 package kafka.demo; 2 3 import java.util.ArrayList; 4 import java.util.List; 5 6 import storm.kafka.KafkaSpout; 7 import storm.kafka.SpoutConfig;...
分类：
其他好文 时间：
2015-12-30 22:06:58
阅读次数：
396
storm是grovvy写的kafka是scala写的storm-kafkastorm连接kafkaconsumer的插件下载地址：https://github.com/wurstmeister/storm-kafka-0.8-plus除了需要storm和kafka相关jar包还需要google-collections-1.0.jar以及zookeeper相关包curator-framework-1.3.3.jar和curator-client..
分类：
其他好文 时间：
2015-10-09 18:29:00
阅读次数：
278
一、原理介绍本文内容参考：https://github.com/apache/storm/tree/master/external/storm-kafka#brokerhosts（一）使用storm-kafka的关键步骤1、创建ZkHosts当storm从kafka中读取某个topic的消息时，需要...
分类：
其他好文 时间：
2015-07-10 22:02:17
阅读次数：
184
一、原理介绍本文内容参考：https://github.com/apache/storm/tree/master/external/storm-kafka#brokerhosts（一）使用storm-kafka的关键步骤1、创建ZkHosts当storm从kafka中读取某个topic的消息时，需要...
分类：
其他好文 时间：
2015-07-10 11:10:18
阅读次数：
2999
Storm-Kafka模块之写入kafka-KafkaBolt的使用及实现...
分类：
其他好文 时间：
2015-01-26 12:02:24
阅读次数：
908
Storm-Kafka模块常用接口分析及使用方式,给出具体使用案例...
分类：
其他好文 时间：
2015-01-22 11:08:23
阅读次数：
183
如何在分布式集群中，充分利用多节点，对大数据进行拆分，实现并行计算，“parallel computing by kafka-storm ” 提供了一种很好的思路。...
分类：
其他好文 时间：
2014-12-29 23:03:01
阅读次数：
208
