前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >FATAL Fatal error during KafkaServerStable startup. Prepare to shutdown (kafka.server.KafkaServerSta

FATAL Fatal error during KafkaServerStable startup. Prepare to shutdown (kafka.server.KafkaServerSta

作者头像
别先生
发布2018-05-16 15:04:14
1.1K0
发布2018-05-16 15:04:14
举报
文章被收录于专栏:别先生别先生

1、启动kafka的时候,报错如下所示:

代码语言:javascript
复制
 1 [2018-04-24 07:32:02,798] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
 2 [2018-04-24 07:32:02,883] FATAL Fatal error during KafkaServerStable startup. Prepare to shutdown (kafka.server.KafkaServerStartable)
 3 java.io.FileNotFoundException: /tmp/kafka-logs/.lock (Permission denied)
 4     at java.io.RandomAccessFile.open(Native Method)
 5     at java.io.RandomAccessFile.<init>(RandomAccessFile.java:241)
 6     at kafka.utils.FileLock.<init>(FileLock.scala:29)
 7     at kafka.log.LogManager$$anonfun$lockLogDirs$1.apply(LogManager.scala:93)
 8     at kafka.log.LogManager$$anonfun$lockLogDirs$1.apply(LogManager.scala:92)
 9     at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
10     at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
11     at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
12     at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:33)
13     at scala.collection.TraversableLike$class.map(TraversableLike.scala:233)
14     at scala.collection.mutable.WrappedArray.map(WrappedArray.scala:33)
15     at kafka.log.LogManager.lockLogDirs(LogManager.scala:92)
16     at kafka.log.LogManager.<init>(LogManager.scala:55)
17     at kafka.server.KafkaServer.createLogManager(KafkaServer.scala:275)
18     at kafka.server.KafkaServer.startup(KafkaServer.scala:72)
19     at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34)
20     at kafka.Kafka$.main(Kafka.scala:46)
21     at kafka.Kafka.main(Kafka.scala)
22 [2018-04-24 07:32:02,890] INFO [Kafka Server 3], shutting down (kafka.server.KafkaServer)
23 [2018-04-24 07:32:02,916] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
24 [2018-04-24 07:32:02,924] INFO Session: 0x262f744ac470001 closed (org.apache.zookeeper.ZooKeeper)
25 [2018-04-24 07:32:02,924] INFO [Kafka Server 3], shut down completed (kafka.server.KafkaServer)
26 [2018-04-24 07:32:02,925] INFO EventThread shut down (org.apache.zookeeper.ClientCnxn)
27 [2018-04-24 07:32:02,928] INFO [Kafka Server 3], shutting down (kafka.server.KafkaServer)

2、原因分析,主要是自己是hadoop用户操作,期间无意登陆到root权限,启动了kafka,且启动成功了,创建了如下所示的目录,而且权限是root权限的,当我切换到hadoop用户的时候,启动kafka直接报如下所示的错误:

3、可以看到目录如下所示,解决方法,可以直接将这个目录删除,重启启动kafka,然后重新生成这个目录即可:

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2018-04-24 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档