Kafka系列之:Kafka生产者和消费者
2023-04-18 16:26:25 时间
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
相关文章
- 直接在代码里面对list集合进行分页
- .NET Framework 4.5新特性详解
- 大数据的简要介绍
- 大数据的由来
- 高斯混合模型的自然梯度变量推理
- timing-wheel 仿Kafka实现的时间轮算法
- 使用Navicat软件连接自建数据库(Linux系统)
- 那一天,我被Redis主从架构支配的恐惧
- Redis 深入了解键的过期时间
- C#使用委托调用实现用户端等待闪屏
- 基于流计算 Oceanus 和 Elasticsearch Service 构建百亿级实时监控系统
- GRAND | 转录调控网络预测数据库
- JFreeChart API中文文档
- 临床相关突变查询数据库
- TIGER | 人类胰岛基因变化查询数据库
- 视频边缘计算网关EasyNVR在视频整体监控解决方案中的应用分析
- Apache Arrow - 大数据在数据湖后的下一个风向标
- 常见的电商数据指标体系
- AKShare-艺人数据-艺人流量价值
- MySQL中多表联合查询与子查询的这些区别,你可能不知道!