如何在配置文件中设置sparksession.readstream属性?

qv7cva1a  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(162)

我第一次使用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()

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题