热门标签
热门文章
- 1Elasticsearch-RestHighLevelClient的使用
- 2Django框架全面讲解 -- 中间件（MiddleWare）_django middleware 只管一个app
- 3如何将我的服务开放给用户：构建API接口和用户认证的实践指南_开放给用户的api
- 4VSCode使用Remote SSH连接远程服务器_vscode连接远程服务器
- 5org.apache.http.NoHttpResponseException：xxx.xxx.com:443 failed to respond
- 6Educational Codeforces Round 100 (Rated for Div. 2) 虚拟参赛及补题。_codeforces虚拟赛加rate吗?
- 7如何创建一个SpringBoot项目？（详细的图文教程）_创建springboot项目
- 8OSS(对象存储服务)与 AWS S3(Amazon Simple Storage Service)_aws s3 帐户
- 9[翻译+注解] DEAP dataset：a dataset for emotion analysis using eeg, physiological and video signals
- 10C++后续：QT学习（Qt概述，创建QT项目）_c++ qt
当前位置: article > 正文
Kafka系列之：Kafka生产者和消费者
作者：weixin_40725706 | 2024-02-12 20:46:53
赞
踩
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&#
推荐阅读
- swagger：swagger 引入
[详细] 赞
踩
相关标签
