You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Wenbing Shen (Jira)" <ji...@apache.org> on 2021/04/21 14:49:00 UTC

[jira] [Commented] (KAFKA-10773) When I execute the below command, Kafka cannot start in local.

    [ https://issues.apache.org/jira/browse/KAFKA-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326600#comment-17326600 ] 

Wenbing Shen commented on KAFKA-10773:
--------------------------------------

Similar to KAFKA-12680. In fact, this is a bug of wsl. The link for this bug is here: [https://github.com/microsoft/WSL/issues/2281]

> When I execute the below command, Kafka cannot start in local.
> --------------------------------------------------------------
>
>                 Key: KAFKA-10773
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10773
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: NAYUSIK
>            Priority: Critical
>         Attachments: image-2020-11-27-19-09-49-389.png
>
>
> When I execute the below command, Kafka cannot start in local.
> *confluent local services start*
> *Please check the below error log and let me know how I modify it.*
> [2020-11-27 18:52:21,019] ERROR Error while deleting the clean shutdown file in dir /tmp/confluent.056805/kafka/data (kafka.server.LogDirFailureChannel)
> java.io.IOException: Invalid argument
>  at java.io.RandomAccessFile.setLength(Native Method)
>  at kafka.log.AbstractIndex.$anonfun$resize$1(AbstractIndex.scala:190)
>  at kafka.log.AbstractIndex.resize(AbstractIndex.scala:176)
>  at kafka.log.AbstractIndex.$anonfun$trimToValidSize$1(AbstractIndex.scala:242)
>  at kafka.log.AbstractIndex.trimToValidSize(AbstractIndex.scala:242)
>  at kafka.log.LogSegment.recover(LogSegment.scala:380)
>  at kafka.log.Log.recoverSegment(Log.scala:692)
>  at kafka.log.Log.recoverLog(Log.scala:830)
>  at kafka.log.Log.$anonfun$loadSegments$3(Log.scala:767)
>  at scala.runtime.java8.JFunction0$mcJ$sp.apply(JFunction0$mcJ$sp.scala:17)
>  at kafka.log.Log.retryOnOffsetOverflow(Log.scala:2626)
>  at kafka.log.Log.loadSegments(Log.scala:767)
>  at kafka.log.Log.<init>(Log.scala:313)
>  at kafka.log.MergedLog$.apply(MergedLog.scala:796)
>  at kafka.log.LogManager.loadLog(LogManager.scala:294)
>  at kafka.log.LogManager.$anonfun$loadLogs$12(LogManager.scala:373)
>  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)
> [2020-11-27 18:52:21,019] ERROR Error while deleting the clean shutdown file in dir /tmp/confluent.056805/kafka/data (kafka.server.LogDirFailureChannel)
> java.io.IOException: Invalid argument
>  at java.io.RandomAccessFile.setLength(Native Method)
>  at kafka.log.AbstractIndex.$anonfun$resize$1(AbstractIndex.scala:190)
>  at kafka.log.AbstractIndex.resize(AbstractIndex.scala:176)
>  at kafka.log.AbstractIndex.$anonfun$trimToValidSize$1(AbstractIndex.scala:242)
>  at kafka.log.AbstractIndex.trimToValidSize(AbstractIndex.scala:242)
>  at kafka.log.LogSegment.recover(LogSegment.scala:380)
>  at kafka.log.Log.recoverSegment(Log.scala:692)
>  at kafka.log.Log.recoverLog(Log.scala:830)
>  at kafka.log.Log.$anonfun$loadSegments$3(Log.scala:767)
>  at scala.runtime.java8.JFunction0$mcJ$sp.apply(JFunction0$mcJ$sp.scala:17)
>  at kafka.log.Log.retryOnOffsetOverflow(Log.scala:2626)
>  at kafka.log.Log.loadSegments(Log.scala:767)
>  at kafka.log.Log.<init>(Log.scala:313)
>  at kafka.log.MergedLog$.apply(MergedLog.scala:796)
>  at kafka.log.LogManager.loadLog(LogManager.scala:294)
>  at kafka.log.LogManager.$anonfun$loadLogs$12(LogManager.scala:373)
>  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)
>  
>  
> [2020-11-27 18:52:22,261] ERROR Shutdown broker because all log dirs in /tmp/confluent.056805/kafka/data have failed (kafka.log.LogManager)



--
This message was sent by Atlassian Jira
(v8.3.4#803005)