设置卡夫卡制作人重试参数重试的实例分析。很多新手对此不是很清楚。为了帮助大家解决这个问题,下面小编就详细讲解一下。需要的人可以从中学习,希望你能有所收获。
00-1010参数的设置通常是一种折衷。查看0.11.3版中重试参数的描述:
设置大于零的值将导致客户端重新发送
发送失败并可能出现暂时错误的任何记录。
请注意,这种重试与客户端重新发送
收到错误时记录。
允许重试而不将max . in . flight . requests . per . connection设置为1可能会改变
记录的排序,因为如果两个批次被发送到一个
分区,第一次失败并重试,但第二次成功,
那么第二批中的记录可能会首先出现。注意:当发送失败时,客户端将重试,重试次数由重试次数指定,此参数默认设置为0。也就是快速失败模式,当传输失败后,客户端会处理以后是否继续传输。将重试次数设置为大于0而不设置max . in . flight . requests . per . connection=1意味着放弃发送消息的顺序。
00-1010使用重试的默认值由用户自己控制,结果往往不处理。因此,一般设置建议如下:
重试次数=整数。最大值
max . in . flight . requests . per . connection=1注意:在此设置之后,发送客户端将重试,直到代理返回ack;同时,只有一个连接向broker发送数据,保证了数据的顺序。在Leader选举中,当集群中的一个代理挂机时,发送方将重试,直到Leader选举结束。避免因客户端未处理的异常导致的数据丢失,例如,当遇到类似“此服务器不是该主题分区的领导者”的情况时,它会自动恢复。
00-1010此参数的设置已设置为整数。最大值;在卡夫卡2.4版本中默认;同时增加了delivery.timeout.ms的参数设置。
生成器重试配置的默认值已更改为
整数。MAX_VALUE,正如我们在KIP-91中介绍的那样,
它设置了发送
记录并接收经纪人的确认。
默认情况下,传递超时设置为2分钟。
kip-91: https://cwiki.apache.org/confluence/display/KAFKA/KIP-91提供直观的用户超时在生产者它会帮助你看完以上内容吗?如果您想了解更多相关知识或阅读更多相关文章,请关注行业资讯频道,感谢您的支持。
内容来源网络,如有侵权,联系删除,本文地址:https://www.230890.com/zhan/99783.html