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){

>>阅读原文<<