首页
技术小册
AIGC
面试刷题
技术文章
MAGENTO
云计算
视频课程
源码下载
PDF书籍
「涨薪秘籍」
登录
注册
Kafka简介
Kafka工作流程
Kafka存储机制
Kafka分区机制
Kafka生产者与消费者
Kafka ack机制
安装Kafka
Producer消息缓存模型
指定副本作为Leader
Kafka的ISR伸缩机制
acks和mir配置详解
Kafka主动修改分区Leader
Kafka向Server发起请求
当前位置:
首页>>
技术小册>>
kafka入门到实战
小册名称：kafka入门到实战
producer端设置request.required.acks=0；只要请求已发送出去，就算是发送完了，不关心有没有写成功。性能很好，如果是对一些日志进行分析，可以承受丢数据的情况，用这个参数，性能会很好。 request.required.acks=1；发送一条消息，当leader partition写入成功以后，才算写入成功。不过这种方式也有丢数据的可能。 request.required.acks=-1；需要ISR列表里面，所有副本都写完以后，这条消息才算写入成功。 设计一个不丢数据的方案：数据不丢失的方案：1)分区副本 >=2 2)acks = -1 3)min.insync.replicas >=2。 下面给出此时leader出现故障的情况，可以看出，此时数据可能重复。 
上一篇：
Kafka生产者与消费者
下一篇：
安装Kafka
该分类下的相关小册推荐：
Kafka面试指南
Kafka核心源码解读
Kafka核心技术与实战
Kafka 原理与源码精讲
消息队列入门与进阶
