linger.ms的异步卡夫卡生产者批次大小

Question

我有一个关于优化kafka异步生成器流程的问题:配置batch.size和linger.ms在使用异步生成器时会产生影响？

我之所以这样问，是因为我认为这些参数只会影响同步生成器，因为它会等待代理acknowledgment.In情况下的异步生成器，这不会产生影响吗？

另外，是否有任何配置参数可以优化异步生成器？

Answer 1

这两个属性都会对异步Kafka生产者产生影响：

linger.ms-> This instruct the producer upto this configured value(ex:2 millisecond) if batch size is not fill up. There will be latency of 2 ms in case message flow is low.



batch.size -> Message buffer size that will be send in single request. Higher batch size also request more memory (buffer.memory)

acks=all , Slowest but most durable configuration, wait for acknowledgement of all message sent.

有关详细信息，您可以查看Kafka文档：https://kafka.apache.org/23/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html