1、spark通过scala创建 new KafkaProducer[String,String](props)提示Cannot resolve overloaded constructorKafkaProducer[String,String],如下图所示:
2、出现此错误时使用的类型不对,只需要将HashMap更换为:Properties即可,如下图所示:
本版积分规则 发表回复 回帖并转播 回帖后跳转到最后一页
QQ咨询|关于我们|Archiver|手机版|小黑屋|( 辽ICP备15012455号-4 ) Powered by 期权论坛 X3.2 © 2001-2016 期权工具网&期权论坛 Inc.
下载期权论坛手机APP