βravo東東.⊰

是的。

谢谢 我明白了 我仔细看了我的问题 是我自己建的Topic报错的.我自建的Topic是1个partition,1个replica 所以我应该只需要重新分配这个出问题的分区就可以了吧。

{"topic":"自建的Topic","partition":0,"replicas":[0]}

O(∩_∩)O

你需要确认报错的topic是__consumer_offsets的分区，只迁移报错的分区就没问题。

ps: 尽量别都放到0这个节点上，平均一点。

感谢你的回复！ 这篇文章是我看的第一篇，我比较疑惑，告警的分区是指比如

New: {epoch:0, offset:16941854}, Current: {epoch:1, offset13646164}

这里那么我重新分配

{"topic":"__consumer_offsets","partition":0,"replicas":[0]}
{"topic":"__consumer_offsets","partition":1,"replicas":[0]}

就行了吗？

可以参考这篇文章：Kafka Broker 日志警告无法消除 : Received a PartitionLeaderEpoch assignment for an epoch < latestEpoch