5.2. 数据持久性

消息发送确认可最小化消息丢失的可能性。默认情况下，使用 acks=all 设置的 acks 属性启用确认。

...
...

# ...
acks=all 

# ...

acks=all 设置提供最强的交付保证，但它会增加生成者发送消息和接收确认之间的延迟。如果您不要求这种强大的保证，则设置 acks=0 或 acks=1 不提供交付保证，或者仅确认领导副本已将记录写入日志中。

使用 acks=all 时，领导会等待所有同步的副本确认消息发送。主题的 min.insync.replicas 配置设置最低同步副本确认数量。确认的数量包括领导和后续者。

典型的起点是使用以下配置：

创建主题时，您可以覆盖默认复制因素。您还可以在主题配置的主题级别上覆盖 min.insync.replicas。

AMQ Streams 在示例配置文件中使用此配置进行 Kafka 的多节点部署。

下表描述了此配置根据复制领导副本的后续者的可用性。

3 主题复制因素会创建一个领导副本和两个后续者。在此配置中，如果单个后续程序不可用时，生产者可以继续。有些延迟可能会从同步的副本中删除失败的代理或创建新领导。如果第二个后续者也不可用，消息发送将无法成功。领导向生产者发送一个错误(不足够副本)，而不是确认成功消息发送。生产者引发等同的异常。通过 重试 配置，生成者可以重新发送失败的消息请求。