从kafka里面消费数据，就是连接不到kafka，在kafka里面生成和消费都没有问题，也没有报错，求大神指教哪里有问题，我也从来没遇到过这个问题，求指教？

Question

我的代码是这样的：

package com.zhidian.zhidian_sparkStreaming

import org.apache.spark.SparkConf

import org.apache.spark.SparkContext

import org.apache.spark.streaming.StreamingContext

import org.apache.spark.streaming.Seconds

import org.apache.spark.streaming.kafka.KafkaUtils

object sparkStreaming {

def main(args: Array[String]): Unit = {

val conf =new SparkConf().setMaster("local[5]").setAppName("kafka")
val sc=new SparkContext(conf)
val ssc=new StreamingContext(sc,Seconds(5))

//指定zookeeper集群地址
val zkHosts="000.000.000.00:2181"
//指定消费者组名，自定义的（消费数据时，组间共享，组内竞争）
val groupId="gp1"
//通过Map来指定消费的主题名和线程数(至少一个)
val topics=Map("video"->1,"enbook"->1)
//通过整合包提供的工具类，实现从kafka消费数据
val kafkaSource=KafkaUtils.createStream(ssc, zkHosts, groupId, topics)
kafkaSource.print()
ssc.start()
ssc.awaitTermination()

}
}

一直就是只出这个，不会出kafka里面的内容

Answer 1

https://blog.csdn.net/a1165117473/article/details/83791106