Kafka报错:Controller 219 epoch 110 failed to change state for partition

这篇具有很好参考价值的文章主要介绍了Kafka报错:Controller 219 epoch 110 failed to change state for partition。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

集群里面kafka报错:

Controller 219 epoch 110 failed to change state for partition maxwell_atlas-0 from OfflinePartition to OnlinePartition

kafka.common.stateChangeFailedException: Failed to elect leader for partition maxwell_atlas-0 under strategy OfflinePartitionLeaderElectionStrategy

Kafka报错:Controller 219 epoch 110 failed to change state for partition,大数据,kafka,Powered by 金山文档

错误原因:

新增加的副本的offset比leader的新,所以在elecct的时候,报错。

解决办法:

kafka自带平衡topic的脚本,只需要启动一遍即可。来到kafka的bin目录下执行命令:

kafka-preferred-replica-election.sh --bootstrap-server ip:2181

然后重启kafka。

然而实际,重启好了不到5分钟,整个集群依然报警了。

再看日志文件,多了些其他报错

[Controller id=219] Partition __consumer_offsets-8 failed to complete preferred replica leader election to 139. Leader is still 141

而在仔细检查所有kafka的实例,发现现有的Kafka.BrokerId有:140,141,142,143,219,而选举leader的id却是139。都可以盲猜一手,现在的219就是之前的139。

从这儿也可以推断出:

  1. 现有的5个节点的partition都不是最新的,所以有主控制器Offline,因为选不出leader

  1. 具体选不出leader的原因,应该就是原来有brokerid=139的,现在没了,而replic partitions,isr里还是原来的139,所以现在的140,141,142,143,219里选举不出139的为leader。

解决办法:

将219所在brokerid改为139后,重启kafka。

重启产生新的报错:

Fatal error during KafkaServer startup. Prepare to shutdown.

Configured broker.id 139 doesn't match stored broke.id 219 in meta.properties.If you moved your data, make sure your configured broker.id matches.

问题原因:

启动kafka时,配置文件中的broke.id和元数据里保存的broker.id不一致导致的启动失败。

解决办法:

前去kafka的数据目录下找到meta.properties文件,修改broker.id=219为139,然后重启。再按上面那个报错处理topic。文章来源地址https://www.toymoban.com/news/detail-609015.html

到了这里,关于Kafka报错:Controller 219 epoch 110 failed to change state for partition的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 恢复 Substrate 链: unexpected epoch changes

    使用 Substrate 定制的区块链,所有节点听了一段时间后,链无法工作。 Substrate:polkadot-v0.9.25 共识协议: babe + grandpa 系统:macOS Big Sur (11.3) cargo: cargo 1.63.0-nightly (a4c1cd0eb 2022-05-18) babe 协议算法,要求每个 epoch(session) 周期内都需要出块,因此当链出现以下情况,导致无法正常出

    2024年01月16日
    浏览(25)
  • failed to start daemon: Error initializing network controller: Error creating default “bridge“ netw

    failed to start daemon: Error initializing network controller: Error creating default \\\"bridge\\\" network: Failed to program NAT chain: INVALID_ZONE: docker linux 重启防火墙 输入此命令重启防火墙 systemctl enable firewalld  重新启动docker即可 systemctl start docker

    2024年02月04日
    浏览(48)
  • linux-clickhouse启动报错- Unit clickhouse-server.service entered failed state

    注意这行报错: 找到日志目录 假如报警日志很大的话 就查看最近500 1000条就好了 提示这个202308_930387_930387_0文件损坏,结构需要清理 进入文件夹 找到提示的文件夹 虽然文件命名成功了,但是clickhouse还是无法启动,还是类似报错,应该是clickhouse还是会使用这个文件 想着怎么

    2024年02月10日
    浏览(25)
  • git报错can‘t push refs to remote. Try running “Pull“ first to integrate to your changes

      这是我在使用git提交代码到GitHub上时遇到的一个报错,刚遇到此问题,内心充满了恐惧,不知如何解决,花了不少时间查资料,因此有必要在此记录一下,同时希望可以为读者提供一定参考。   在远程创建空仓库,然后本地写一些代码,尝试提交到远程时,出现标题所指的

    2024年02月08日
    浏览(58)
  • Failed to construct kafka producer

    问题重述: org.apache.kafka.common.KafkaException: Failed to construct kafka producer Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers Kafka连接不上 解决办法: 将kafka信息输入到hosts文件中 文件地址 使用Notepad++打开,输入ip地址和kafka名称

    2024年01月18日
    浏览(27)
  • git报错-Your local changes to the following files would be overwritten by merge:

    有一天我在服务器拉取git仓库的代码时报错如下   大概意思就是试图合并一个分支到你的当前分支,但是在你的当前分支上,有三个 .pyc 文件有本地未提交的修改。这些修改如果进行合并操作,将会被合并过来的分支中的对应文件内容覆盖。 错误信息建议在合并之前,你需

    2024年04月10日
    浏览(39)
  • 解决跨域报错:Access to XMLHttpRequest at ‘http://110.40.173.100:5173/api/user/login‘ from origin ‘http://1

    前言: 最近在完成一个项目的时候,在发送请求的时候,浏览器报错: Access to XMLHttpRequest at \\\'http://110.40.173.100:5173/api/user/login\\\' from origin \\\'http://127.0.0.1:5173\\\' has been blocked by CORS policy: Response to preflight request doesn\\\'t pass access control check: No \\\'Access-Control-Allow-Origin\\\' header is present on the r

    2024年04月15日
    浏览(56)
  • git pull报错:error: Your local changes to the following files would be overwritten by merge:

    合作项目,之前用笔记本把代码做了一些修改、提交,修改完成。第二天忘了先 git pull 到本地,直接进行编写,突然想起忘了 pull 了,然后想用 git pull 来更新本地代码,结果报错: error: Your local changes to the following files would be overwritten by merge: 意思是我本地上新修改的代码的

    2024年02月04日
    浏览(44)
  • IDEA GIt切换分支报错:Your local changes to the following files would be overwritten by Checkout.

    一、前言 在我们本地有未commit的文件时,使用IDEA切换分支的时候会报如图所示错误: 意思就是对当前分支文件的更改会被Checkout覆盖。可以搁置更改然后签出和取消搁置。 二、解决办法 方案1、将文件commit 方案二、stash方式 三、Git命令 Terminal输入命令如下 推荐使用第二种方

    2024年02月02日
    浏览(49)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包