我查阅了很多关于apachekafka事务、恢复和新特性的文章。还是不明白消费者复苏的问题。如何确保队列中的每一条消息都会得到处理，即使其中一个消费者死亡？假设我们有一个主题分区分配给消费者。消费者轮询消息并开始处理它。由于电源故障而关闭。会发生什么？同一组的其他消费者是否会重新发送此消息？
ve7v8dk21#
消费者定期发送心跳信号，告诉经纪人他们还活着。如果代理没有接收到来自消费者的心跳信号，它将认为消费者已死亡并重新分配其分区。因此，如果使用者死亡，其分区将被分配给组中的另一个使用者，未提交的消息将被发送给新分配的使用者。
1条答案
按热度按时间ve7v8dk21#
消费者定期发送心跳信号，告诉经纪人他们还活着。如果代理没有接收到来自消费者的心跳信号，它将认为消费者已死亡并重新分配其分区。因此，如果使用者死亡，其分区将被分配给组中的另一个使用者，未提交的消息将被发送给新分配的使用者。