[
https://issues.apache.org/jira/browse/KAFKA-4071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430091#comment-15430091
]
Zane Zhang commented on KAFKA-4071:
-----------------------------------
The contents of corrupted replication-offset-checkpoint
Nê-;O
W%
__hit_offsetprodTopicDal09Dä Ó-VZ5ðV"ðNê-?O*ü@%
__hit_offsetprodTopicDal09D%tVZ5òV"òNê-QO%äã:%
__hit_offsetprodTopicDal09D. gÝVZ6
V"
Nê-\Oaê4ç%
__hit_offsetprodTopicDal09D
ÑVZ6V"Nê-]OR
L%
__hit_offsetprodTopicDal09DÒ VZ6V"Nê-_O÷¸%
__hit_offsetprodTopicDal09D2
iVZ6V
> Corruptted replication-offset-checkpoint leads to kafka server disfunctional
> ----------------------------------------------------------------------------
>
> Key: KAFKA-4071
> URL: https://issues.apache.org/jira/browse/KAFKA-4071
> Project: Kafka
> Issue Type: Bug
> Components: clients, offset manager
> Affects Versions: 0.9.0.1
> Environment: Red Hat Enterprise 6.7
> Reporter: Zane Zhang
>
> For an unknown reason, [kafka data root]/replication-offset-checkpoint was
> corrupted. First Kafka reported an NumberFormatException in kafka sever.out.
> And then it reported "error when handling request Name: FetchRequest; ... "
> ERRORs repeatedly (ERROR details below). As a result, clients cannot read
> from or write to Kafka on several partitions until
> replication-offset-checkpoint was manually deleted.
> ERROR [KafkaApi-7] error when handling request
> java.lang.NumberFormatException: For input string: " N?-; O"
> at
> java.lang.NumberFormatException.forInputString(NumberFormatException.java:77)
> at java.lang.Integer.parseInt(Integer.java:493)
> at java.lang.Integer.parseInt(Integer.java:539)
> at
> scala.collection.immutable.StringLike$class.toInt(StringLike.scala:272)
> at scala.collection.immutable.StringOps.toInt(StringOps.scala:30)
> at kafka.server.OffsetCheckpoint.read(OffsetCheckpoint.scala:78)
> at kafka.cluster.Partition.getOrCreateReplica(Partition.scala:93)
> at
> kafka.cluster.Partition$$anonfun$4$$anonfun$apply$2.apply(Partition.scala:173)
> at
> kafka.cluster.Partition$$anonfun$4$$anonfun$apply$2.apply(Partition.scala:173)
> at scala.collection.immutable.Set$Set2.foreach(Set.scala:111)
> at kafka.cluster.Partition$$anonfun$4.apply(Partition.scala:173)
> ERROR [KafkaApi-7] error when handling request Name: FetchRequest; Version:
> 1; CorrelationId: 0; ClientId: ReplicaFetcherThread-1-7; ReplicaId: 6;
> MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [prodTopicDal09E,166] ->
> PartitionFetchInfo(7123666,20971520),[prodTopicDal09E,118] ->
> PartitionFetchInfo(7128188,20971520),[prodTopicDal09E,238] ->
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
