版本

来源:4-9 -Kafka Producer Java API编程

qq_慕婉清419998

2019-07-25

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

写回答

2回答

weixin_慕田峪8372375

2019-07-30

这里是直接将properties传入KafkaProducer即可,不需要new一个ProducerConfig再传进去了,因为这里的KafkaProducer构造函数会自己调用ProducerConfig。//img.mukewang.com/szimg/5d4031ed096ceaf909470199.jpg

0
2
Michael_PK
回复
weixin_慕田峪8372375
不同版本可能写法不同,而且也有可能有重载的几个方法
2019-07-30
共2条回复

Michael_PK

2019-07-25

produce config的参数不对,是不是kafka版本问题?

0
0

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程