KafkaSpout 淺析

最近在使用storm做一個實時計算的項目,Spout需要從 KAFKA 集群中讀取數據，為了提高開發效率，直接使用了Storm提供的KAFKA插件。今天抽空看了一下KafkaSpout的源碼，記錄下心得體會。 KafkaSpout ...

kafka+storm連接

本項目為maven項目，需要添加必要的storm庫，以及kafka依賴，使用storm自帶的storm-kafka進行連接，根據自己集群環境 <dependency> & ...