小编Ami*_*yar的帖子

KAFKA 重启问题:无法在不删除 /tmp/kafka-logs 的情况下重启 kafka

每当我尝试重新启动 kafka 时,它都会出现以下错误。一旦我删除 /tmp/kafka-logs 它就会得到解决,但它也会删除我的主题。有办法解决吗?

     ERROR Error while deleting the clean shutdown file in dir /tmp/kafka-logs (kafka.server.LogDirFailureChannel)
java.io.IOException: Invalid argument
        at java.io.RandomAccessFile.setLength(Native Method)
        at kafka.log.AbstractIndex$$anonfun$resize$1.apply$mcZ$sp(AbstractIndex.scala:128)
        at kafka.log.AbstractIndex$$anonfun$resize$1.apply(AbstractIndex.scala:115)
        at kafka.log.AbstractIndex$$anonfun$resize$1.apply(AbstractIndex.scala:115)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
        at kafka.log.AbstractIndex.resize(AbstractIndex.scala:115)
        at kafka.log.AbstractIndex$$anonfun$trimToValidSize$1.apply$mcZ$sp(AbstractIndex.scala:184)
        at kafka.log.AbstractIndex$$anonfun$trimToValidSize$1.apply(AbstractIndex.scala:184)
  kafka.log.LogManager.kafka$log$LogManager$$loadLog(LogManager.scala:265)
        at kafka.log.LogManager$$anonfun$loadLogs$2$$anonfun$11$$anonfun$apply$15$$anonfun$apply$2.apply$mcV$sp(LogManager.scala:345)
        at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:63)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
[2018-11-02 16:00:07,126] INFO Logs loading complete in 4323 ms. (kafka.log.LogManager)
[2018-11-02 16:00:07,134] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
[2018-11-02 16:00:07,136] INFO Starting log …
Run Code Online (Sandbox Code Playgroud)

apache-kafka

7
推荐指数
1
解决办法
1222
查看次数

标签 统计

apache-kafka ×1