kafka0.8版本和sparkstreaming整合的两种不一样方式

1- kafka-082以上kafka-010如下 1-1 基于receiver的方式 1-1-1 重写Receiver的onStart方法 1-1-1-1 构造BlockGenerator时会构造一个定时器 1-1-1-2 另一个在blockGenerator中的线程是 1-1-1-3 线程池 1-1-1-4 构造kafka消息流返回MapStringListKafkaStreamKV 1-1-

>>阅读原文<<