You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Nikilesh (Jira)" <ji...@apache.org> on 2023/05/16 09:48:00 UTC

[jira] [Updated] (KAFKA-14998) Kafka server start fails with the following error java.lang.NumberFormatException: For input string: "a"

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

Nikilesh updated KAFKA-14998:
-----------------------------
    Description: 
Kafka fails to start because of the following error. The Kafka cluster was in a healthy state all along in a kubernetes environment and this issue started happening as part of upgrade to k8s cluster and no changes to kafka as such in terms of configuration.

 

 
{code:java}
[2023-05-16 02:29:32,159] ERROR [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.NumberFormatException: For input string: "a"
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:309)
at scala.collection.immutable.StringLike.toLong$(StringLike.scala:309)
at scala.collection.immutable.StringOps.toLong(StringOps.scala:33)
at kafka.log.Log$.offsetFromFileName(Log.scala:2568)
at kafka.log.Log$.offsetFromFile(Log.scala:2572)
at kafka.log.Log.$anonfun$loadSegmentFiles$3(Log.scala:597)
at scala.collection.TraversableLike$WithFilter.$anonfun$foreach$1(TraversableLike.scala:877)
at scala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:36)
at scala.collection.IndexedSeqOptimized.foreach$(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:198)
at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:876)
at kafka.log.Log.loadSegmentFiles(Log.scala:586)
at kafka.log.Log.$anonfun$loadSegments$1(Log.scala:697)
at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
at kafka.log.Log.retryOnOffsetOverflow(Log.scala:2329)
at kafka.log.Log.loadSegments(Log.scala:691)
at kafka.log.Log.<init>(Log.scala:297)
at kafka.log.Log$.apply(Log.scala:2463)
at kafka.log.LogManager.loadLog(LogManager.scala:272)
at kafka.log.LogManager.$anonfun$loadLogs$12(LogManager.scala:342)
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)
{code}
 

  was:
Kafka fails to restart because of the following error. The Kafka cluster was in a healthy state all along in a kubernetes environment and this issue started happening as part of upgrade to k8s cluster and no changes to kafka as such in terms of configuration.

 

 
{code:java}
[2023-05-16 02:29:32,159] ERROR [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.NumberFormatException: For input string: "a"
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:309)
at scala.collection.immutable.StringLike.toLong$(StringLike.scala:309)
at scala.collection.immutable.StringOps.toLong(StringOps.scala:33)
at kafka.log.Log$.offsetFromFileName(Log.scala:2568)
at kafka.log.Log$.offsetFromFile(Log.scala:2572)
at kafka.log.Log.$anonfun$loadSegmentFiles$3(Log.scala:597)
at scala.collection.TraversableLike$WithFilter.$anonfun$foreach$1(TraversableLike.scala:877)
at scala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:36)
at scala.collection.IndexedSeqOptimized.foreach$(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:198)
at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:876)
at kafka.log.Log.loadSegmentFiles(Log.scala:586)
at kafka.log.Log.$anonfun$loadSegments$1(Log.scala:697)
at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
at kafka.log.Log.retryOnOffsetOverflow(Log.scala:2329)
at kafka.log.Log.loadSegments(Log.scala:691)
at kafka.log.Log.<init>(Log.scala:297)
at kafka.log.Log$.apply(Log.scala:2463)
at kafka.log.LogManager.loadLog(LogManager.scala:272)
at kafka.log.LogManager.$anonfun$loadLogs$12(LogManager.scala:342)
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)
{code}
 


> Kafka server start fails with the following error java.lang.NumberFormatException: For input string: "a"
> --------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-14998
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14998
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 2.5.1
>            Reporter: Nikilesh
>            Priority: Major
>
> Kafka fails to start because of the following error. The Kafka cluster was in a healthy state all along in a kubernetes environment and this issue started happening as part of upgrade to k8s cluster and no changes to kafka as such in terms of configuration.
>  
>  
> {code:java}
> [2023-05-16 02:29:32,159] ERROR [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
> java.lang.NumberFormatException: For input string: "a"
> 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:309)
> at scala.collection.immutable.StringLike.toLong$(StringLike.scala:309)
> at scala.collection.immutable.StringOps.toLong(StringOps.scala:33)
> at kafka.log.Log$.offsetFromFileName(Log.scala:2568)
> at kafka.log.Log$.offsetFromFile(Log.scala:2572)
> at kafka.log.Log.$anonfun$loadSegmentFiles$3(Log.scala:597)
> at scala.collection.TraversableLike$WithFilter.$anonfun$foreach$1(TraversableLike.scala:877)
> at scala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:36)
> at scala.collection.IndexedSeqOptimized.foreach$(IndexedSeqOptimized.scala:33)
> at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:198)
> at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:876)
> at kafka.log.Log.loadSegmentFiles(Log.scala:586)
> at kafka.log.Log.$anonfun$loadSegments$1(Log.scala:697)
> at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
> at kafka.log.Log.retryOnOffsetOverflow(Log.scala:2329)
> at kafka.log.Log.loadSegments(Log.scala:691)
> at kafka.log.Log.<init>(Log.scala:297)
> at kafka.log.Log$.apply(Log.scala:2463)
> at kafka.log.LogManager.loadLog(LogManager.scala:272)
> at kafka.log.LogManager.$anonfun$loadLogs$12(LogManager.scala:342)
> 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)
> {code}
>  



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