kafka 报错： LEADER_NOT_AVAILABLE
重装kafka的时候， 出现了如下报错：Error while fetching metadata with correlation id 2 : LEADER_NOT_AVAILABLE
重装的步骤
1： 停止kafka
2： 登入zookeeper， 删除kafka的依赖
[hadoop@fdc01 bin]$ ./zookeeper-client
[zk: localhost:2181(CONNECTED) 2] rmr /controller
需要删除的有[cluster, controller, brokers,admin, isr_change_notification, log_dir_event_notification, controller_epoch,consumers, latest_producer_id_block, config]
3: 重装kafka
然后出现报错如下：
Error while fetching metadata with correlation id 2 : LEADER_NOT_AVAILABLE
kafka 报错： LEADER_NOT_AVAILABLE相关推荐
- kafka报错LEADER_NOT_AVAILABLE
三点集群,之前运行ok,重启后报错: Error while fetching metadata with correlation id 10 : {yqjp-devices-sendPackage= ...
- kafka 报错：kafka server：Message was too large ，server rejected it to avoid allocation
kafka报错信息: kafka server:Message was too large ,server rejected it to avoid allocation kafka版本: kafk ...
- 【Flink】Flink 写入 kafka 报错 The server disconnected before a response was received
文章目录 1.场景再现 1.1.概述 1.场景再现 1.1.概述 Flink 写入 kafka 报错 The server disconnected before a response was rec ...
- 【Spark】Spark Stream读取kafka写入kafka报错 AbstractMethodError
1.概述 根据这个博客 [Spark]Spark 2.4 Stream 读取kafka 写入kafka 报错如下 Exception in thread "main" java.l ...
- kafka报错：creating broker listeners from xxx unable to parse xxx:9092 to a broker endpoint
1.美图 2.背景 kafka报错:creating broker listeners from xxx unable to parse xxx:9092 to a broker endpoint 具 ...
- 【Kafka】kafka报错 UnknownHostException: %HOSTGROUP::host_group_zookeeper%: Temporary failure in name re
1.概述 背景和这个有关:[Kafka]docker下kafka报错 IOException: Connection to xxx:19093 (id: 1002 rack: null) failed ...
- Kafka : 报错 KafkaController NoSuchElementException : : key not found : [xxx]
1.美图 2.背景 运行中的kafka 报错如下 目前还没找到原因 参考:KafkaKAFKA-415 参考:KafkaKAFKA-3239
- kafka报错：Error writing out kafka.log:type=Log,name=LogStartOffset,topic=xx EofException
文章目录 1.美图 2.背景 1.美图 2.背景 cdh启动kafka报错,错误代码如下 Error writing out kafka.log:type=Log,name=LogStartOffse ...
- Flink读取Kafka报错：KafkaException ByteArrayDeserializer is not an instance Deserializer
1.视界 2.背景 做flink读取kafka报错 org.apache.kafka.common.KafkaException: Failed to construct kafka consumer ...
- flume 对接 kafka 报错： Error while fetching metadata with correlation id 35 {=INVALID_TOPIC_EXCEPTION}
flume 对接 kafka 报错:Error while fetching metadata with correlation id 35 : {=INVALID_TOPIC_EXCEPTION} ...
最新文章
- 与基础事务管理器通讯失败
- python之cookies
- 安卓 sharedpreferences可以被其它activity读取_【安卓逆向】“一份礼物”之我要o泡逆向分析...
- java readtoend_java项目和C#项目实现通信
- Linux常用命令(第二版) --压缩解压缩命令
- Tomcat 修改JSESSIONID
- 项目中缺少maven dependencis，或者pom文件报红
- 计算机应用基础精品课程申报表,《计算机应用基础》精品课程申报书(修改意见)...
- 【Python】Python实战从入门到精通之三 -- 教你使用Python中条件语句
- EntityFrameWork连接多Db配置
- python自动化开发和全栈开发_python全栈开发devops运维自动化方向初到高级在线课程分享...
- 做{...}而（0） - 有什么好处？ [重复]
- 【Python】排序函数 sort、sorted 对复杂列表排序
- 员工考勤管理系统c语言,员工考勤信息管理小程序，考勤信息管理小程序
- 电气技术应用和计算机应用,电气技术应用专业介绍 ppt课件.ppt
- 大数据平台解决方案（PPT）
- 条码仓库管理系统在食品行业中的应用
- （JavaScript案例）可拖动的模态框
- 你没见过的中文编程工具，用中文开发android安卓应用，安卓开发的初体验！
- 人体红外感应的c语言程序,CC2530控制人体红外传感器的程序与详细教程