你的理解部分正确。
正如@leshkin所指出的，有一些配置参数可以调整kafkaproducer如何处理要发送的消息的缓冲。
但是，独立于缓冲策略，生产者将负责缓存到主题引导代理的已建立连接。
实际上，您可以使用 connections.max.idle.ms 参数（默认为9分钟）。
因此，为了回答您最初的问题，与代理建立连接的i/o成本只发生在第一个阶段 send 只要您有数据要发送，调用和将随时间摊销。

kafka producer的两个重要配置参数是'batch.size'和'linger.ms'。因此，您基本上有一个选择：您可以等到生产商批次已满，或者生产商超时。
batch.size–这是kafka producer在发送前尝试批处理的消息数的上限–以字节为单位指定。
linger.ms–生产者在发送之前要等待多长时间，以便在同一批中累积更多的消息。
这取决于您的用例，但我建议您仔细研究一下这些参数。

在以下情况下，您需要在kafka prodocer中配置batch.size、linger.ms和compression.type属性以提高性能。
1） 如果唱片到达的速度比Kafka制作人发送的速度快。
2） 如果你有大量的数据在你各自的主题，它真的负担你的Kafka生产者。
3） 如果你有瓶颈

batch.size = 16_384 * 4
 linger.ms 200
compression.type = "snappy"

props.put(ProducerConfig.BATCH_SIZE_CONFIG, 16_384 * 4);
    // Send with little bit buffering
    props.put(ProducerConfig.LINGER_MS_CONFIG, 200);    
  //Use Snappy compression for batch compression.
    props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "snappy");

Kafka·佐内
性能调优
Kafka表演