Kafka异常问题记录

一、Kafka关闭后，再次启动失败问题

问题描述：kafka关闭后，再次重启失败，异常日志如下：

[2022-02-17 16:13:40,739] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID NAdv6Mq7Qoy-g0ui7WV-9g doesn't match stored clusterId Some(qyuVCe-ST_C39fp34FEV8Q) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.at kafka.server.KafkaServer.startup(KafkaServer.scala:252)at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)at kafka.Kafka$.main(Kafka.scala:82)at kafka.Kafka.main(Kafka.scala)
[2022-02-17 16:13:40,742] INFO shutting down (kafka.server.KafkaServer)
[2022-02-17 16:13:40,744] INFO [feature-zk-node-event-process-thread]: Shutting down (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2022-02-17 16:13:40,744] INFO [feature-zk-node-event-process-thread]: Stopped (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2022-02-17 16:13:40,745] INFO [feature-zk-node-event-process-thread]: Shutdown completed (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2022-02-17 16:13:40,746] INFO [ZooKeeperClient Kafka server] Closing. (kafka.zookeeper.ZooKeeperClient)
[2022-02-17 16:13:40,850] INFO Session: 0x103d8f7a5700002 closed (org.apache.zookeeper.ZooKeeper)
[2022-02-17 16:13:40,850] INFO EventThread shut down for session: 0x103d8f7a5700002 (org.apache.zookeeper.ClientCnxn)
[2022-02-17 16:13:40,852] INFO [ZooKeeperClient Kafka server] Closed. (kafka.zookeeper.ZooKeeperClient)
[2022-02-17 16:13:40,855] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)
[2022-02-17 16:13:40,855] INFO shut down completed (kafka.server.KafkaServer)
[2022-02-17 16:13:40,856] ERROR Exiting Kafka. (kafka.server.KafkaServerStartable)
[2022-02-17 16:13:40,857] INFO shutting down (kafka.server.KafkaServer)

解决办法：修改kafka数据文件目录中的meta.properties文件。

/mnt/tmp/kafka-logs，具体文件路径看自己的kafka系统配置。

删除此行数据，再次启动kafka，即可重启成功。

Kafka异常问题记录相关推荐

java将异常输出到日志_【ThinkingInJava】25、将异常输出记录到日志
/** * 书本:<Thinking In Java> * 功能:将异常输出记录到日志中. * 文件:LoggingExceptions.java * 时间:2015年4月8日21:11: ...
Log4Net异常日志记录在asp.net mvc3.0的应用
前言 log4net是.Net下一个非常优秀的开源日志记录组件.log4net记录日志的功能非常强大.它可以将日志分不同的等级,以不同的格式,输出到不同的媒介.本文主要是简单的介绍如何在Visual ...
IE8下JQuery clone 出的select元素使用append添加option异常解决记录
IE8下JQuery clone 出的select元素使用append添加option异常解决记录参考文章: (1)IE8下JQuery clone 出的select元素使用append添加opti ...
HBase中此类异常解决记录org.apache.hadoop.ipc.RemoteException(java.io.IOException):
HBase中此类异常解决记录org.apache.hadoop.ipc.RemoteException(java.io.IOException): 参考文章: (1)HBase中此类异常解决记录org ...
Kafka 异常 : DefaultOffsetCommitCallback.onComplete(ConsumerCoordinator.java:537) -Offset commit faile
Kafka 异常 : DefaultOffsetCommitCallback.onComplete(ConsumerCoordinator.java:537) -Offset commit faile ...
python 修饰器_python中用修饰器进行异常日志记录
当脚本中需要进行的的相同的异常操作很多的时候,可以用修饰器来简化代码.比如我需要记录抛出的异常: 在log_exception.py文件中, import functools import loggi ...
Storm消费Kafka异常 - topic其中两个分区达到某个值不进行消费，持续阻塞
Kafka消费storm,突然有两个分区无法消费数据(或重复消费无法提交offset) offset是我们自己进行管理,kafka日志也是正常没有报错,storm日志也是没有报错~ 就是卡住了 1.尝 ...
C#错误异常日志记录到文件
当我们将网站布署到线上之后,为了实时了解网站的运行情况,如是否有错误页面.网站运行速度.是否有攻击等.那么我们就很有必要为网站加上错误与异常记录到日志文件,这样就可以随时查看网站的线上运行情况,另有一 ...
ASP.NET Web API 异常日志记录
如果在 ASP.NET MVC 应用程序中记录异常信息,我们只需要在 Global.asax 的 Application_Error 中添加代码就可以了,比如: public class MvcApp ...

Kafka异常问题记录

一、Kafka关闭后，再次启动失败问题

问题描述：kafka关闭后，再次重启失败，异常日志如下：

解决办法：修改kafka数据文件目录中的meta.properties文件。

Kafka异常问题记录相关推荐

最新文章

热门文章