hello Fredo, Can you provide your program's code? There might be some clues
On Wed, Nov 25, 2015 at 2:27 PM, Fredo Lee <buaatianwa...@gmail.com> wrote: > four kafka nodes, i get these errors > one node, it works well. > > 2015-11-25 14:52 GMT+08:00 Fredo Lee <buaatianwa...@gmail.com>: > > > > > 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) > > > -- Muqtafi Akhmad Software Engineer Traveloka
