kafka启动报错:Failed to acquire lock on file .lock in /tmp/kafka-log

Posted 飘然渡沧海

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafka启动报错:Failed to acquire lock on file .lock in /tmp/kafka-log相关的知识,希望对你有一定的参考价值。

kafka

org.apache.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. a n o n f u n anonfun anonfunlockLogDirs 1 ( L o g M a n a g e r . s c a l a : 239 ) a t s c a l a . c o l l e c t i o n . S t r i c t O p t i m i z e d I t e r a b l e O p s . f l a t M a p ( S t r i c t O p t i m i z e d I t e r a b l e O p s . s c a l a : 117 ) a t s c a l a . c o l l e c t i o n . S t r i c t O p t i m i z e d I t e r a b l e O p s . f l a t M a p 1(LogManager.scala:239) at scala.collection.StrictOptimizedIterableOps.flatMap(StrictOptimizedIterableOps.scala:117) at scala.collection.StrictOptimizedIterableOps.flatMap 1(LogManager.scala:239)atscala.collection.StrictOptimizedIterableOps.flatMap(StrictOptimizedIterableOps.scala:117)atscala.collection.StrictOptimizedIterableOps.flatMap(StrictOptimizedIterableOps.scala:104)
at scala.collection.mutable.ArraySeq.flatMap(ArraySeq.scala:38)
at kafka.log.LogManager.lockLogDirs(LogManager.scala:234)
at kafka.log.LogManager.(LogManager.scala:105)
at kafka.log.LogManager . a p p l y ( L o g M a n a g e r . s c a l a : 1111 ) a t k a f k a . s e r v e r . K a f k a S e r v e r . s t a r t u p ( K a f k a S e r v e r . s c a l a : 273 ) a t k a f k a . s e r v e r . K a f k a S e r v e r S t a r t a b l e . s t a r t u p ( K a f k a S e r v e r S t a r t a b l e . s c a l a : 44 ) a t k a f k a . K a f k a .apply(LogManager.scala:1111) at kafka.server.KafkaServer.startup(KafkaServer.scala:273) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44) at kafka.Kafka .apply(LogManager.scala:1111)atkafka.server.KafkaServer.startup(KafkaServer.scala:273)atkafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)atkafka.Kafka.main(Kafka.scala:82)
at kafka.Kafka.main(Kafka.scala)

兄弟们啊,再次声明一定要回看日志啊,他妈博客上一群傻逼教学。佛了
上面明明说的是

A Kafka instance in another process or thread is using this directory.

文档标题钓鱼,看到这句话翻译翻译什么他妈叫惊喜!

关闭重启就行了

 kafka-server-stop.sh 

还不行的话,看下端口

ps -ef|grep kafka

kill -9 pid

以上是关于kafka启动报错:Failed to acquire lock on file .lock in /tmp/kafka-log的主要内容,如果未能解决你的问题,请参考以下文章

SpringBoot中使用Kafka报错:Failed to construct kafka consumer

kafka.common.KafkaException: Failed to acquire lock on file .lock in /tmp/kafka-logs. A Kafka instan

FlinkFlink 写入 kafka 报错 Failed to send data to Kafka: Expiring 4 record(s) for 20001 ms has passed(代码

Kafka日志报错:[error] k.m.j.KafkaJMX$ - Failed to connect to service:jmx:rmi:///jndi/rmi://10.1.3.116:-1

Failed to get nested archive for entry BOOT-INF/lib/spring-kafka-2.2.7.RELEASE.jar

Kafka报错ERROR Shutdown broker because all log dirs in ... have failed