小编HIR*_*ALA的帖子

如何从属性文件设置 Kafka 参数?

我目前正在做的事情如下:

val topic = "mytopic"
val zkhosts = "localhost"
val zkports = "2181"
Run Code Online (Sandbox Code Playgroud)

在我的代码中设置它然后将它发送到 kafkastream 函数可以工作,但我想从.properties文件中读取它。有没有可能的解决方案?

apache-kafka apache-spark spark-streaming

6
推荐指数
1
解决办法
2548
查看次数