kafka 运行问题：kafka.common.KafkaException: Failed to acquire lock on file .lock 的处理

我就是我 2022-06-16 08:54 355阅读 0赞

文章目录

1、概述
    2、问题描述
    3、解决方法

--------------------

1、概述
    
    kafka 运行问题，kafka 异常退出后重启的问题。

--------------------

2、问题描述
    
    [2016-08-31 10:42:36,015] INFO shutting down (kafka.server.KafkaServer)
    [2016-08-31 10:42:36,017] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
    [2016-08-31 10:42:36,032] INFO EventThread shut down (org.apache.zookeeper.ClientCnxn)
    [2016-08-31 10:42:36,032] INFO Session: 0x256de78ba570000 closed (org.apache.zookeeper.ZooKeeper)
    [2016-08-31 10:42:36,040] INFO shut down completed (kafka.server.KafkaServer)
    [2016-08-31 10:42:36,040] FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown (kafka.server.KafkaServerStartable)
    kafka.common.KafkaException: Failed to acquire lock on file .lock in /tmp/kafka-logs. A Kafka instance in another process or thread is using this directory.
        at kafka.log.LogManager$$anonfun$lockLogDirs$1.apply(LogManager.scala:98)
    	    at kafka.log.LogManager$$anonfun$lockLogDirs$1.apply(LogManager.scala:95)
        at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)
    	    at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)
        at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
        at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:35)
        at scala.collection.TraversableLike$class.map(TraversableLike.scala:245)
        at scala.collection.AbstractTraversable.map(Traversable.scala:104)
        at kafka.log.LogManager.lockLogDirs(LogManager.scala:95)
        at kafka.log.LogManager.<init>(LogManager.scala:57)
        at kafka.server.KafkaServer.createLogManager(KafkaServer.scala:589)
        at kafka.server.KafkaServer.startup(KafkaServer.scala:171)
        at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37)
        at kafka.Kafka$.main(Kafka.scala:67)
        at kafka.Kafka.main(Kafka.scala)

--------------------

3、解决方法
    
    * 删除 /tmp/kafka-logs；
    * netstat -lnp|grep 9092；并且 kill pid；
    * 又将移除的 /tmp/kafka-logs 移回，启动正常。