Kafka的ack机制，指的是producer的消息发送确认机制，这直接影响到Kafka集群的吞吐量和消息可靠性。而吞吐量和可靠性就像硬币的两面，两者不可兼得，只能平衡。 ACK有3个可选值，分别是1，0，-1。 ACK = 0 时， 发送一次 不论leader是否接收 ACK = 1 时 ...

一、 kafka读写流程 写流程 读流程 二、数据可靠性保证 为保证 producer 发送的数据，能可靠的发送到指定的 topic，topic 的每个 partition 收到 producer 发送的数据后，都需要向 producer 发送 ack ...

我们吧！ Kafka有两个很重要的配置参数，acks与min.insync.re ...

request.required.acks 有三个值 0 1 -1(all) 0:生产者不会等待 broker 的 ack，这个延迟最低但是存储的保证最弱当 server 挂 掉的时候就会丢数据。 1：服务端会等待 ack 值 leader 副本确认接收到消息后发送 ack ...

at-most-once（可能少读） ack=0 发送不管接收成功与否 at-least-once（可能重复读）ack=-1 主从分区都接收成功事务才成功 exactly-once （正好）= at-least-once+幂等性 ack=1 主分区接收成功事务就成功 ...

（0）写在前面 面试大厂时，一旦简历上写了Kafka，几乎必然会被问到一个问题：说说acks参数对消息持久化的影响？ 这个acks参数在kafka的使用中，是非常核心以及关键的一个参数，决定了很多东西。 所以无论是为了面试还是实际项目使用，大家都值得看一下这篇文章对Kafka的acks参数 ...

ACK——消息确认机制 　　在实际使用RocketMQ的时候我们并不能保证每次发送的消息都刚好能被消费者一次性正常消费成功，可能会存在需要多次消费才能成功或者一直消费失败的情况，那作为发送者该做如何处理呢？ 　　为了保证数据不被丢失，RabbitMQ支持消息确认机制，即ack。发送者 ...

1、什么是消息确认ACK。 　　答：如果在处理消息的过程中，消费者的服务器在处理消息的时候出现异常，那么可能这条正在处理的消息就没有完成消息消费，数据就会丢失。为了确保数据不会丢失，RabbitMQ支持消息确定-ACK。 2、RabbitMQ的ACK的消息确认机制。 1、ACK机制是消费者 ...