[
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)
