Storm-kafka集成——1.1.0版本storm中tuple取KafkaSpout數據詳解

問題描述： KafkaSpout拉取kafka topic數據，下一級bolt從kafkaspout獲取數據，tuple到底採用什麼方法取出spout中的消息呢？ KafkaSpout創建： /* *根據數據源topic和zk_id創建並返回kafkaSpout * */ public static KafkaSpout init(String spout_topic,String zk_id){

>>阅读原文<<