当前位置:   article > 正文

深入浅出理解kafka原理系列之:发送消息的缓冲区机制buffer.memory、batch.size、linger.ms_kafka batch.size和buffer.memory

kafka batch.size和buffer.memory

深入浅出理解kafka原理系列之:发送消息的缓冲区机制buffer.memory、batch.size、linger.ms

  • kafka默认会创建一个消息缓冲区,用来存放要发送的消息,缓冲区是32M
  • kafka本地线程会去缓冲区中一次拉16k的数据,发送到broker
  • 如果线程拉不到16k的数据,间隔10ms也会将已拉到的数据发送到broker

一、buffer.memory

  • 设置发送消息的本地缓冲区,如果设置了该缓冲区,消息会先发送到本地缓冲区,可以提高消息发送性能。默认值是33554432,即32MB
props.put("buffer.memory", 33554432
    声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/很楠不爱3/article/detail/78499?site
    推荐阅读
    相关标签
      

    闽ICP备14008679号