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

我的代码是这样的:

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里面的内容

查看全部
xiaoshian
TokinMa
2020/06/03 19:17
  • scala
  • 点赞
  • 收藏
  • 回答
    私信
满意答案
查看全部

1个回复