Kafka系列之：Kafka生产者和消费者
Kafka系列之：Kafka生产者和消费者
- 一、Kafka生产者发送流程
- 二、提高生产者吞吐量
- 三、Kafka消费方式
- 四、Kafka消费者总体工作流程
- 五、按照时间消费Kafka Topic
一、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