Fredo, Thanks for reporting this. Are you starting a brand new 0.9.0.0 cluster? Are there steps that one can follow to reproduce this issue easily?
Jun On Tue, Nov 24, 2015 at 10:52 PM, Fredo Lee <buaatianwa...@gmail.com> wrote: > The content below is the report for kafka > > when i try to fetch coordinator broker, i get 6 for ever. > > > > [2015-11-25 14:48:28,638] ERROR [KafkaApi-1] error when handling request > Name: FetchRequest; Version: 1; CorrelationId: 643; ClientId: > ReplicaFetcherThread-0-4; ReplicaId: > 1; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [__consumer_offsets,49] > -> PartitionFetchInfo(0,1048576),[__consumer_offsets,17] -> > PartitionFetchInfo(0,1048576),[__con > sumer_offsets,29] -> PartitionFetchInfo(0,1048576),[blcs,6] -> > PartitionFetchInfo(0,1048576),[__consumer_offsets,41] -> > PartitionFetchInfo(0,1048576),[__consumer_offsets,13 > ] -> PartitionFetchInfo(0,1048576),[__consumer_offsets,5] -> > PartitionFetchInfo(0,1048576),[__consumer_offsets,37] -> > PartitionFetchInfo(0,1048576),[__consumer_offsets,25] > -> PartitionFetchInfo(0,1048576),[__consumer_offsets,1] -> > PartitionFetchInfo(0,1048576) (kafka.server.KafkaApis) > kafka.common.KafkaException: Should not set log end offset on partition > [__consumer_offsets,49]'s local replica 1 > at kafka.cluster.Replica.logEndOffset_$eq(Replica.scala:66) > at kafka.cluster.Replica.updateLogReadResult(Replica.scala:53) > at > kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:240) > at > > kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:852) > at > > kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:849) > at > scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:221) > at > scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428) > at > > kafka.server.ReplicaManager.updateFollowerLogReadResults(ReplicaManager.scala:849) > at > kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:467) > at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:434) > at kafka.server.KafkaApis.handle(KafkaApis.scala:69) > at > kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) > at java.lang.Thread.run(Thread.java:722) >
