弱弱的问个问题,我用新版本的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