我有一個關于優化kafka異步producer吞吐量的問題:配置batch.size和linger.ms對使用異步producer有影響嗎?
我問是因為我認為這些引數只會影響同步生產者,因為它會等待代理確認。如果是異步生產者,這不會有影響嗎?
另外,是否有任何配置引數可以優化異步生產者?
uj5u.com熱心網友回復:
這兩個屬性都對異步 Kafka Producer 有影響:
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
轉載請註明出處,本文鏈接:https://www.uj5u.com/qukuanlian/469329.html
標籤:爪哇 异步 阿帕奇卡夫卡 kafka-生产者-api
