0


Kafka系列之:Kafka生产者和消费者

Kafka系列之:Kafka生产者和消费者

一、Kafka生产者发送流程

在这里插入图片描述

  • batch.size:只有数据积累到batch.size之后,sender才会发送数据,默认16K。
  • linger.ms:如果数据迟迟未达到batch.size,sender等待linger.ms设置的时间到了之后就会发送数据。单位ms,默认值是0ms,表示没有延迟。
  • 0:生产者发送过来的数据,不需要等数据罗盘应答。
  • 1:生产者发送过来的数据,Leader收到数据后应答。
  • -1:生产者发送过来的数据,Leader和ISR队列里面的所有节点收齐数据后应答,-1和all等价。

二、提高生产者吞吐量

  • batch.size:批次大小,默认16K
  • linger.ms:等待时间,修改为5-100ms

本文转载自: https://blog.csdn.net/zhengzaifeidelushang/article/details/129284470
版权归原作者 最笨的羊羊 所有, 如有侵权,请联系我们删除。

“Kafka系列之:Kafka生产者和消费者”的评论:

还没有评论