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-

>>阅读原文<<