ACK简介 在实际使用RocketMQ的时候我们并不能保证每次发送的消息都刚好能被消费者一次性正常消费成功，可能会存在需要多次消费才能成功或者一直消费失败的情况，那作为发送者该做如何处理呢？ RocketMQ提供了ack机制，以保证消息能够被正常消费。发送者为了保证消息肯定消费成功，只有使用方明确 ...

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

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

　　消息应答时执行一个任务可能需要花费几秒钟，你可能会担心如果一个消费者在执行任务过程中挂掉了。 　　一旦RabbitMQ将消息分发给了消费者，就会从内存中删除。在这种情况下，如果正在执行任务的消费者宕机，会丢失正在处理的消息和分发给这个消费者但尚未处理的消息。 　　但是，我们不想 ...

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

ack机制，即producer发送消息的确认机制，会影响到kafka的消息吞吐量和安全可靠性，二者不可兼得，只能平均； ack的取值有三个1、0、-1 ack=0，producer只发送一次消息，无论consumer是否收到； ack=-1，producer发送的消息，只有收到分区内所有副本 ...

当消息有几万条或者几十万条的时候，如果消费的方式不对，会造成内存崩溃的情况 一：consumer 1. 短链接：basicget 独自去获取message。。。 request 的方式去获取，断开式。。。 2. 长连接：eventbasicconsumer。。。 【订阅式】 1. ...

每个Consumer可能需要一段时间才能处理完收到的数据。如果在这个过程中，Consumer出错了，异常退出了，而数据还没有处理完成，那么 非常不幸，这段数据就丢失了。 因为我们采用no-ack的方式进行确认，也就是说，每次Consumer接到数据后，而不管是否处理完 成 ...