about云日志分析项目-storm-kafka插件的使用

1.storm-kafka插件介绍


2.storm-kafka maven依赖配置
[mw_shl_code=xml,true]<dependency>
   <groupId>org.apache.storm</groupId>
   <artifactId>storm-kafka</artifactId>
   <version>1.0.2</version>
  </dependency>[/mw_shl_code]

3.storm-kafka 开发步骤
获取zookeeper链接信息ip列表
定义kafka topic名称
定义zookeeper根目录
创建BrokerHosts 对象
以上信息作为参数，创建SpoutConfig对象，并设置zookeeper节点IP列表，端口
创建KafkaSpout对象，作为参数传入到setSpout方法中
通过topology 对象的setSpout方法读取kafka信息，信息在Bolt中接收并做相应处理