版本

Question

我Kafka的版本是1.0.3, 在idea上写java 的时候报producer过时了，叫我用KafkaProducer,但传参数的时候又报错了，new KafkaProducer<Integer,String>(new Producerconfig(Properties)) Properties这里报错。请问我该怎么修改呢

Answer 1

weixin_慕田峪8372375 2019-07-30 20:03:04

这里是直接将properties传入KafkaProducer即可，不需要new一个ProducerConfig再传进去了，因为这里的KafkaProducer构造函数会自己调用ProducerConfig。

• weixin_慕田峪8372375 #1

  新版本的kafka关于这个函数有改动，可以看一下源码

• Michael_PK 回复 weixin_慕田峪8372375 #2

  不同版本可能写法不同，而且也有可能有重载的几个方法

Answer 2

Michael_PK 2019-07-25 22:18:23

produce config的参数不对，是不是kafka版本问题？