由于org.apache.kafka.common.errors.NotLeaderForPartitionException，在分区topic-0上的生成请求中收到无效的元数据错误

Question

我们使用spring kafka stream producer向kafka topic生成数据。当我们做弹性测试时，我们得到了下面的错误。

`2020-08-28 16:18:35.536警告，26 - ad | producer-3 o.a.k.clients.producer.internals.Sender : Producer clientId=producer-3在分区topic1-0上收到无效的元数据错误，由于分区org.apache.kafka.common.errors.NotLeaderForPartitionException:此服务器不是该topic- partition的领导者。正在请求元数据更新

日志:2020-08-28 16:18:35.536 WARN，26 - ad | producer-3 o.a.k.clients.producer.internals.Sender : Producer clientId=producer-3在主题分区topic1-0上获取关联id为80187的错误生成响应，正在重试(还剩4次尝试)。错误: NOT_LEADER_FOR_PARTITION

由于org.apache.kafka.common.errors.NotLeaderForPartitionException：，Producer clientId=producer-3在分区topic1-0上的produce请求中收到无效的元数据错误。此服务器不是该topic- partition的领导者。正在请求元数据更新。

警告应该只在我们运行弹性(代理关闭/启动测试)的时间段内出现，但这些警告即使在弹性测试期间之后也会发生，并且只发生在特定分区(这里是topic1-0)。所有其他分区都工作正常。

这是我们拥有的生产者配置：spring.cloud.stream.kafka.binder.requiredAcks=all spring.cloud.stream.kafka.binder.configuration.retries=5 spring.cloud.stream.kafka.binder.configuration.metadata.max.age.ms=3000 spring.cloud.stream.kafka.binder.configuration.max.in.flight.requests.per.connection=1 spring.cloud.stream.kafka.binder.configuration.retry.backoff.ms=10000

我们也重试了配置，它正在重试获取正确的元数据，你可以在上面的日志中看到，但对于那个特定的分区，它总是得到相同的警告。我们的kafka团队也在分析这个问题。我在谷歌上搜索了所有的解决方案，但我找不到有用的。

是否缺少任何配置或其他内容？

请帮帮我。

提前谢谢。

Answer 1

这个错误发生在Kafka宕机的时候。重启Kafka对我很有效！:)