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)
