You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Zane Zhang (JIRA)" <ji...@apache.org> on 2016/08/22 05:51:20 UTC
[jira] [Commented] (KAFKA-4071) Corruptted
replication-offset-checkpoint leads to kafka server disfunctional
[ 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)