storm+kafka测试案例

一.storm本地测试 创建spout 继承 BaseRichSpout 创建bolt 继承 BaseBasicBolt 创建topology 使用TopologyBuilder createTopology()创建 启动topology 使用 LocalCluster submitTopology发布 二.本地storm+kafka 引入storm kafka依赖 创建KafkaSpout 注意

>>阅读原文<<