[jira] [Updated] (KAFKA-14465) java.lang.NumberFormatException: For input string: "index"

["jianbin.chen (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-14465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

jianbin.chen updated KAFKA-14465:
---------------------------------
    Attachment: image-2022-12-15-12-26-24-718.png

> java.lang.NumberFormatException: For input string: "index" 
> -----------------------------------------------------------
>
>                 Key: KAFKA-14465
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14465
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 1.1.0
>            Reporter: jianbin.chen
>            Priority: Major
>         Attachments: image-2022-12-15-12-26-24-718.png
>
>
> {code:java}
> [2022-12-13 07:12:20,369] WARN [Log partition=fp_sg_flow_copy-1, dir=/home/admin/output/kafka-logs] Found a corrupted index file corresponding to log file /home/admin/output/kafk
> a-logs/fp_sg_flow_copy-1/00000000000000000165.log due to Corrupt index found, index file (/home/admin/output/kafka-logs/fp_sg_flow_copy-1/00000000000000000165.index) has non-zero
>  size but the last offset is 165 which is no greater than the base offset 165.}, recovering segment and rebuilding index files... (kafka.log.Log)
> [2022-12-13 07:12:20,369] ERROR There was an error in one of the threads during logs loading: java.lang.NumberFormatException: For input string: "index" (kafka.log.LogManager)
> [2022-12-13 07:12:20,374] INFO [ProducerStateManager partition=fp_sg_flow_copy-1] Writing producer snapshot at offset 165 (kafka.log.ProducerStateManager)
> [2022-12-13 07:12:20,378] INFO [Log partition=fp_sg_flow_copy-1, dir=/home/admin/output/kafka-logs] Loading producer state from offset 165 with message format version 2 (kafka.lo
> g.Log)
> [2022-12-13 07:12:20,381] INFO [Log partition=fp_sg_flow_copy-1, dir=/home/admin/output/kafka-logs] Completed load of log with 1 segments, log start offset 165 and log end offset
>  165 in 13 ms (kafka.log.Log)
> [2022-12-13 07:12:20,389] ERROR [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
> java.lang.NumberFormatException: For input string: "index"
>         at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
>         at java.lang.Long.parseLong(Long.java:589)
>         at java.lang.Long.parseLong(Long.java:631)
>         at scala.collection.immutable.StringLike.toLong(StringLike.scala:306)
>         at scala.collection.immutable.StringLike.toLong$(StringLike.scala:306)
>         at scala.collection.immutable.StringOps.toLong(StringOps.scala:29)
>         at kafka.log.Log$.offsetFromFile(Log.scala:1846)
>         at kafka.log.Log.$anonfun$loadSegmentFiles$3(Log.scala:331)
>         at scala.collection.TraversableLike$WithFilter.$anonfun$foreach$1(TraversableLike.scala:789)
>         at scala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:32)
>         at scala.collection.IndexedSeqOptimized.foreach$(IndexedSeqOptimized.scala:29)
>         at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:191)
>         at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:788)
>         at kafka.log.Log.loadSegmentFiles(Log.scala:320)
>         at kafka.log.Log.loadSegments(Log.scala:403)
>         at kafka.log.Log.<init>(Log.scala:216)
>         at kafka.log.Log$.apply(Log.scala:1748)
>         at kafka.log.LogManager.loadLog(LogManager.scala:265)
>         at kafka.log.LogManager.$anonfun$loadLogs$12(LogManager.scala:335)
>         at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:62)
>         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:750)
> [2022-12-13 07:12:20,401] INFO [KafkaServer id=1] shutting down (kafka.server.KafkaServer)
> {code}
> When I restart the broker, it becomes like this, I deleted the 0000000000000000000165.index file, after starting it, there are still other files with the same error, please tell me how to fix it and what it is causing



--
This message was sent by Atlassian Jira
(v8.20.10#820010)