问题描述
Got error produce response with correlation id 134 on topic-partition XXX,retrying (**2147483581 attempts left)**. Error: NOT_leader_FOR_PARTITION
Received invalid Metadata error in produce request on partition local-XXX-0 due to org.apache.kafka.common.errors.NotleaderForPartitionException: This server is not the leader for that topic-partition.. Going to request Metadata update Now
我在这里担心两件事,一是如何解决错误,我可以理解请求是发送到不是领导者的分区的,但是我该如何解决呢? 第二件事是如何设置重试次数,错误地显示重试次数太大(2147483581),我只想设置2或3次重试。
我尝试添加以下代码,但不适用于从数据库读取数据并推送到kafka群集的spring batch-app。
.faultTolerant().
retryLimit(3).
retry(NotleaderForPartitionException.class)
请在上述两个方面提供提示或帮助。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)