在Kaka Producer中配置重试的最佳方式

Question

同步副本配置为Acks=all和min.insync。N=N，

想了解如何为未处理的生产者记录的消息/记录配置重试

例如：当Kafka无法使用ISR在线处理记录时，处理过程中的ISR为N-1，最小配置ISR为N个副本。

Answer 1

对于上述场景，您将获得NotNoughReplicateScexception。在这个阶段，Kafka将消息的默认重试值重设为0

Answer 2

什么是阿克斯？

ACK参数控制在生产商可以考虑写入成功之前，多个分区副本必须接收记录。

acks参数有三个值：

acks=0时，生产者将不会等待代理的回复，然后再假定消息已成功发送。

acks=1，在领导者副本收到消息的那一刻，生产者将收到来自代理的成功响应。如果消息不能写入领导者，生产者将收到错误响应，并可以重试。

acks=all，一旦所有同步副本接收到消息，生产者将从代理收到成功响应。

在您的情况下，acks=all，这是最安全的方法，因为您可以确保更多的经纪人拥有消息。

重试：

如果生产者收到错误消息，那么retries属性的值就会出现在图片中。您可以使用“重试”。退后。ms属性来配置重试间隔时间。建议测试从崩溃的代理恢复所需的时间，并设置重试次数和两次重试之间的延迟，以使重试所花费的总时间比Kafka群集从零开始恢复所需的时间更长。

另外，请查看下面的链接，

https://www.confluent.io/blog/hands-free-kafka-replication-a-lesson-in-operational-simplicity/