[2013-10-24 08:56:06,010] INFO [Replica Manager on Broker 2]: Handling LeaderAndIsr request Name:LeaderAndIsrRequest;Version:0;Controller:1;ControllerEpoch:2;CorrelationId:8;ClientId:id_1-host_null-port_9092;PartitionState:(mvlogs,1) -> (LeaderAndIsrInfo:(Leader:2,ISR:2,LeaderEpoch:2,ControllerEpoch:2),ReplicationFactor:2),AllReplicas:2,0),(mvlogs,3) -> (LeaderAndIsrInfo:(Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:2),ReplicationFactor:2),AllReplicas:0,2);Leaders:id:2,host:CH1SCH050041618,port:9092 (kafka.server.ReplicaManager)
[2013-10-24 08:56:06,012] INFO [ReplicaFetcherManager on broker 2] Removing fetcher for partition [mvlogs,1] (kafka.server.ReplicaFetcherManager)
[2013-10-24 08:56:06,014] ERROR Error on broker 2 while processing LeaderAndIsr request correlationId 8 received from controller 1 epoch 2 for partition (mvlogs,1) (state.change.logger)
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.Short.parseShort(Short.java:117)
                at java.lang.Short.parseShort(Short.java:143)
                at scala.collection.immutable.StringLike$class.toShort(StringLike.scala:230)
                at scala.collection.immutable.StringOps.toShort(StringOps.scala:31)
                at kafka.server.HighwaterMarkCheckpoint.read(HighwaterMarkCheckpoint.scala:88)
                at kafka.cluster.Partition.getOrCreateReplica(Partition.scala:83)
                at kafka.cluster.Partition$$anonfun$1.apply(Partition.scala:149)
                at kafka.cluster.Partition$$anonfun$1.apply(Partition.scala:149)
                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.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
                at scala.collection.immutable.List.foreach(List.scala:76)
                at scala.collection.TraversableLike$class.map(TraversableLike.scala:233)
                at scala.collection.immutable.List.map(List.scala:76)
                at kafka.cluster.Partition.makeLeader(Partition.scala:149)
                at kafka.server.ReplicaManager.kafka$server$ReplicaManager$$makeLeader(ReplicaManager.scala:257)
                at kafka.server.ReplicaManager$$anonfun$becomeLeaderOrFollower$4.apply(ReplicaManager.scala:221)
                at kafka.server.ReplicaManager$$anonfun$becomeLeaderOrFollower$4.apply(ReplicaManager.scala:213)
                at scala.collection.immutable.Map$Map2.foreach(Map.scala:140)
                at kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:213)
                at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:86)
                at kafka.server.KafkaApis.handle(KafkaApis.scala:69)
                at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
                at java.lang.Thread.run(Thread.java:724)
[2013-10-24 08:56:06,015] INFO [ReplicaFetcherManager on broker 2] Removing fetcher for partition [mvlogs,3] (kafka.server.ReplicaFetcherManager)
[2013-10-24 08:56:06,015] ERROR Error on broker 2 while processing LeaderAndIsr request correlationId 8 received from controller 1 epoch 2 for partition (mvlogs,3) (state.change.logger)
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.Short.parseShort(Short.java:117)
                at java.lang.Short.parseShort(Short.java:143)
                at scala.collection.immutable.StringLike$class.toShort(StringLike.scala:230)
                at scala.collection.immutable.StringOps.toShort(StringOps.scala:31)
                at kafka.server.HighwaterMarkCheckpoint.read(HighwaterMarkCheckpoint.scala:88)
                at kafka.cluster.Partition.getOrCreateReplica(Partition.scala:83)
                at kafka.cluster.Partition$$anonfun$1.apply(Partition.scala:149)
                at kafka.cluster.Partition$$anonfun$1.apply(Partition.scala:149)
                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.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
                at scala.collection.immutable.List.foreach(List.scala:76)
                at scala.collection.TraversableLike$class.map(TraversableLike.scala:233)
                at scala.collection.immutable.List.map(List.scala:76)
                at kafka.cluster.Partition.makeLeader(Partition.scala:149)
                at kafka.server.ReplicaManager.kafka$server$ReplicaManager$$makeLeader(ReplicaManager.scala:257)
                at kafka.server.ReplicaManager$$anonfun$becomeLeaderOrFollower$4.apply(ReplicaManager.scala:221)
                at kafka.server.ReplicaManager$$anonfun$becomeLeaderOrFollower$4.apply(ReplicaManager.scala:213)
                at scala.collection.immutable.Map$Map2.foreach(Map.scala:140)
                at kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:213)
                at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:86)
                at kafka.server.KafkaApis.handle(KafkaApis.scala:69)
                at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
                at java.lang.Thread.run(Thread.java:724)
[2013-10-24 08:56:06,017] INFO [Replica Manager on Broker 2]: Handled leader and isr request Name:LeaderAndIsrRequest;Version:0;Controller:1;ControllerEpoch:2;CorrelationId:8;ClientId:id_1-host_null-port_9092;PartitionState:(mvlogs,1) -> (LeaderAndIsrInfo:(Leader:2,ISR:2,LeaderEpoch:2,ControllerEpoch:2),ReplicationFactor:2),AllReplicas:2,0),(mvlogs,3) -> (LeaderAndIsrInfo:(Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:2),ReplicationFactor:2),AllReplicas:0,2);Leaders:id:2,host:CH1SCH050041618,port:9092 (kafka.server.ReplicaManager)
[2013-10-24 08:56:06,045] WARN [KafkaApi-2] Produce request with correlation id 2 from client  on partition [mvlogs,1] failed due to Leader not local for partition [mvlogs,1] on broker 2 (kafka.server.KafkaApis)
[2013-10-24 08:56:06,205] INFO Closing socket connection to /10.65.127.77. (kafka.network.Processor)