我尝试推送到本地服务器上运行的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次尝试。
我尝试添加下面的代码，但它不适用于我的spring批处理应用程序，它从数据库读取数据并推送到kafka集群。

.faultTolerant().
retryLimit(3).
retry(NotLeaderForPartitionException.class)

请在上述两点上提供提示或帮助。