kafka发送消息慢修订版本明细

源

采纳

编辑于

Ｅiaranˉ

kafka发送消息慢

kafka

弱弱的问个问题：最近发现生产者发送信息正常，关闭连接用时不定，有时需要几秒钟才能关闭。
之前现网都是正常的，最近有几个连接比较频繁的生产者出现连接耗时比较长，导致业务数据延迟比较厉害，大神这是什么原因？

retries=0
linger.ms=1
acks=all
buffer.memory=33554432
batch.size=16384
connections.max.idle.ms=10000
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.StringSerializer

public void send(String messages) {
        if(messages.isEmpty()){
            return;
        }
        producer.send(new ProducerRecord<String, String>(TOPIC,messages));
    }

public void close(){
        producer.close();
    }

用kafka自带的压测试了如下：

bin/kafka-producer-perf-test.sh --topic test --num-records 100 --record-size 1 --throughput 100  --producer-props bootstrap.servers=localhost:9092

100 records sent, 21.519260 records/sec (0.00 MB/sec), 128.99 ms avg latency, 3674.00 ms max latency, 12 ms 50th, 124 ms 95th, 3674 ms 99th, 3674 ms 99.9th.

预览