kafka直连的代码和解释（还有几个类没有搞明白）

    1 .KafkaUtils.createDirectStream[ 这四个泛型：k就是topic，v就是topic对应的内容从kafkhtml Kd （解码器）vd（解码器）]   这个方法是在各个分区没有偏移量时的用的。apache 后面的参数是（ssc，kafkaparam，topics）是怎么回事，尤为是kafkaparam这个参数？？？bootstrap     答：咱们直接Kaf

>>阅读原文<<