jianbin.chen created KAFKA-14465:
------------------------------------
Summary: 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
{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)
