关于Kafka生产者抛出NotEnoughReplicas异常的时机及重试机制的技术问询

Kafka min.insync.replicas 相关行为：你的问题解答 #

先快速对齐核心背景：

当生产者设置 acks="all"（或 -1）时，min.insync.replicas 指定了写入操作被视为成功前必须确认的最小同步副本数。如果无法满足这个最小值，生产者会抛出 NotEnoughReplicas 或 NotEnoughReplicasAfterAppend 异常。将它与 acks="all" 配合使用能强化持久性——比如经典的复制因子为3、min.insync.replicas=2、acks="all" 的配置，能确保当多数副本未接收到写入时，生产者会抛出异常。

接下来逐一解答你的两个技术问题：

1. 当ISR队列副本数小于min.insync.replicas且生产者acks设为all时，是立即抛出NotEnoughReplicas异常，还是等待超时后再抛出？

当生产者以 acks="all" 发送消息时，broker会在处理请求的第一步就检查当前ISR的大小：

• 如果此时ISR中的副本数量已经小于 min.insync.replicas 的值，broker会立刻返回 NotEnoughReplicas 异常，生产者会直接抛出这个错误，不会等待超时。
• 要注意区分这种情况和「ISR数量达标但副本同步过慢超时」的场景：后者是ISR足够，但部分副本同步消息的耗时超过了 request.timeout.ms，此时生产者会抛出 TimeoutException，而非 NotEnoughReplicas。

2. 生产者接收到该错误时，若未达到最大重试次数，是否会进行重试？

默认情况下，是的，生产者会自动重试NotEnoughReplicas异常，直到达到 retries 参数（或由 delivery.timeout.ms 间接控制的重试次数上限）：

• NotEnoughReplicas 被Kafka生产者客户端归类为「可重试异常」，因为这类问题通常是临时的（比如离线的副本重新加入ISR）。
• 你可以通过 retry.backoff.ms 参数调整两次重试之间的间隔，避免频繁重试给broker带来压力。
• 如果你想取消对该异常的重试，可以自定义 RetryPolicy（比如在Java客户端中实现接口，将 NotEnoughReplicasException 标记为不可重试）。

内容的提问来源于stack exchange，提问作者Smokeriu