我目前正在做的事情如下:
val topic = "mytopic" val zkhosts = "localhost" val zkports = "2181"
在我的代码中设置它然后将它发送到 kafkastream 函数可以工作,但我想从.properties文件中读取它。有没有可能的解决方案?
.properties
apache-kafka apache-spark spark-streaming
apache-kafka ×1
apache-spark ×1
spark-streaming ×1