kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Manikumar (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (KAFKA-1505) Broker failed to start because of corrupted replication-offset-checkpoint file
Date Mon, 04 Sep 2017 11:22:00 GMT

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

Manikumar resolved KAFKA-1505.
------------------------------
    Resolution: Fixed

This was fixed in newer versions.  Pl reopen if you think the issue still exists


> Broker failed to start because of corrupted replication-offset-checkpoint file
> ------------------------------------------------------------------------------
>
>                 Key: KAFKA-1505
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1505
>             Project: Kafka
>          Issue Type: Bug
>          Components: replication
>    Affects Versions: 0.8.1
>         Environment: Window Server 2012;JDK1.7.0
>            Reporter: Jie Tong
>            Assignee: Neha Narkhede
>
> The replication-offset-checkpoint file seems to have some blank entries where the topic,
partition, offset information is expected.
> Broker service cannot be started with following error:
> [2014-06-18 11:09:51,272] ERROR [KafkaApi-5] error when handling request Name:LeaderAndIsrRequest;Version:0;Controller:2;ControllerEpoch:35;CorrelationId:11;ClientId:id_2-host_10.65.127.89-port_9092;PartitionState:(x,4)
-> (LeaderAndIsrInfo:(Leader:14,ISR:14,LeaderEpoch:33,ControllerEpoch:35),ReplicationFactor:3),AllReplicas:14,5,6),(xm,20)
-> (LeaderAndIsrInfo:(Leader:11,ISR:11,4,LeaderEpoch:11,ControllerEpoch:32),ReplicationFactor:3),AllReplicas:11,4,5),(xm,0)
-> (LeaderAndIsrInfo:(Leader:11,ISR:11,4,LeaderEpoch:28,ControllerEpoch:32),ReplicationFactor:3),AllReplicas:11,4,5),(xm_int,3)
-> (LeaderAndIsrInfo:(Leader:17,ISR:17,18,LeaderEpoch:26,ControllerEpoch:30),ReplicationFactor:3),AllReplicas:5,17,18),(x_int,9)
-> (LeaderAndIsrInfo:(Leader:11,ISR:11,LeaderEpoch:38,ControllerEpoch:35),ReplicationFactor:3),AllReplicas:11,5,6),(xm_int,11)
-> (LeaderAndIsrInfo:(Leader:13,ISR:13,LeaderEpoch:29,ControllerEpoch:35),ReplicationFactor:3),AllReplicas:13,5,6),(x_int,3)
-> (LeaderAndIsrInfo:(Leader:19,ISR:19,0,LeaderEpoch:25,ControllerEpoch:32),ReplicationFactor:3),AllReplicas:5,19,0),(xm,1)
-> (LeaderAndIsrInfo:(Leader:12,ISR:12,LeaderEpoch:30,ControllerEpoch:35),ReplicationFactor:3),AllReplicas:12,5,6),(x,3)
-> (LeaderAndIsrInfo:(Leader:13,ISR:13,4,LeaderEpoch:22,ControllerEpoch:32),ReplicationFactor:3),AllReplicas:13,4,5),(xm,14)
-> (LeaderAndIsrInfo:(Leader:18,ISR:18,19,LeaderEpoch:24,ControllerEpoch:31),ReplicationFactor:3),AllReplicas:5,18,19),(xm_int,10)
-> (LeaderAndIsrInfo:(Leader:12,ISR:12,4,LeaderEpoch:25,ControllerEpoch:32),ReplicationFactor:3),AllReplicas:12,4,5),(x,15)
-> (LeaderAndIsrInfo:(Leader:17,ISR:17,16,LeaderEpoch:24,ControllerEpoch:30),ReplicationFactor:3),AllReplicas:5,16,17),(x_int,8)
-> (LeaderAndIsrInfo:(Leader:10,ISR:10,4,LeaderEpoch:26,ControllerEpoch:32),ReplicationFactor:3),AllReplicas:10,4,5),(xm,21)
-> (LeaderAndIsrInfo:(Leader:12,ISR:12,LeaderEpoch:8,ControllerEpoch:35),ReplicationFactor:3),AllReplicas:12,5,6);Leaders:id:11,host:25.126.81.157,port:9092,id:14,host:25.126.81.159,port:9092,id:12,host:25.126.81.158,port:9092,id:17,host:10.153.63.196,port:9092,id:18,host:10.153.63.214,port:9092,id:19,host:10.65.127.95,port:9092,id:13,host:10.65.127.93,port:9092,id:10,host:10.65.127.92,port:9092
(kafka.server.KafkaApis)
> java.lang.NumberFormatException: For input string: "                                
                                                                                         
                                                                                         
                                   "
>                 at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
>                 at java.lang.Integer.parseInt(Integer.java:481)
>                 at java.lang.Integer.parseInt(Integer.java:527)
>                 at scala.collection.immutable.StringLike$class.toInt(StringLike.scala:231)
>                 at scala.collection.immutable.StringOps.toInt(StringOps.scala:31)
>                 at kafka.server.OffsetCheckpoint.liftedTree2$1(OffsetCheckpoint.scala:77)
>                 at kafka.server.OffsetCheckpoint.read(OffsetCheckpoint.scala:73)
>                 at kafka.cluster.Partition.getOrCreateReplica(Partition.scala:91)
>                 at kafka.server.ReplicaManager$$anonfun$makeFollowers$5.apply(ReplicaManager.scala:347)
>                 at kafka.server.ReplicaManager$$anonfun$makeFollowers$5.apply(ReplicaManager.scala:346)
>                 at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
>                 at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
>                 at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
>                 at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
>                 at scala.collection.Iterator$class.foreach(Iterator.scala:772)
>                 at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
>                 at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
>                 at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
>                 at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
>                 at scala.collection.TraversableLike$class.map(TraversableLike.scala:233)
>                 at scala.collection.mutable.HashMap.map(HashMap.scala:45)
>                 at kafka.server.ReplicaManager.makeFollowers(ReplicaManager.scala:346)
>                 at kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:248)
>                 at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:93)
>                 at kafka.server.KafkaApis.handle(KafkaApis.scala:74)
>                 at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
>                 at java.lang.Thread.run(Thread.java:724)



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message