storm+kafka測試案例

一.storm本地測試 創建spout 繼承 BaseRichSpout 創建bolt 繼承 BaseBasicBolt 創建topology 使用TopologyBuilder createTopology()創建 啓動topology 使用 LocalCluster submitTopology發佈 二.本地storm+kafka 引入storm kafka依賴 創建KafkaSpout 注意

>>阅读原文<<