服务器不是Spring-batch中该主题分区错误的领导者

如何解决服务器不是Spring-batch中该主题分区错误的领导者

尝试推送到在本地运行的kafka集群时出现错误，错误是：

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)

请在上述两个方面提供提示或帮助。