返回到文章

采纳

编辑于

kafka生产者客户端发送消息慢

kafka

弱弱的问个问题,我用新版本的org.apache.kafka.clients.producer.ProducerRecord.send(record)发送消息很慢,需要200毫秒左右,

而用老版本的kafka.javaapi.producer.Producer.send(record)发送消息反而快非常多。

一台Linux虚拟机,单机部署zookeeper和kafka,测试时用新版本producer发送500条数据,第一条50毫秒左右,后面的都是200毫秒左右。

下面是生产者客户端配置,大神帮忙看看哪里出问题了,谢谢

retries=0
linger.ms=0
acks=1
buffer.memory=33554432
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.StringSerializer