我第一次使用spark结构化流媒体,也是第一次与Kafka进行spark会话。我知道如何使用spark上下文的配置文件来设置conf属性,但在spark会话中我看不到这么简单。下面是我的spark会话配置
val incoming_data = spark
.readStream
.format("kafka")
.option("kafka.bootstrap.servers", "boot_strap_server_list")
.option("subscribe", "topic_name")
.load()
暂无答案!
目前还没有任何答案,快来回答吧!