kafka直連的代碼和解釋（還有幾個類沒有搞明白）

    1 .KafkaUtils.createDirectStream[ 這四個泛型：k就是topic，v就是topic對應的內容從kafkhtml Kd （解碼器）vd（解碼器）]   這個方法是在各個分區沒有偏移量時的用的。apache 後面的參數是（ssc，kafkaparam，topics）是怎麼回事，尤爲是kafkaparam這個參數？？？bootstrap     答：咱們直接Kaf

>>阅读原文<<