Are you running any non-java client, especially a consumer? Thanks,
Jun On Wed, Nov 25, 2015 at 6:38 PM, Fredo Lee <buaatianwa...@gmail.com> wrote: > this is my config file for original file with some changed by me. > > broker.id=1 > listeners=PLAINTEXT://:9092 > num.partitions=10 > log.dirs=/tmp/kafka-logs1 > zookeeper.connect=localhost:2181 > zookeeper.connection.timeout.ms=2000 > delete.topic.enable=true > default.replication.factor=2 > auto.leader.rebalance.enable=true > > > if i change listeners to 9093, it works!!!! There is no process running on > this port!! > i donot know why > > > 2015-11-25 23:58 GMT+08:00 Jun Rao <j...@confluent.io>: > > > 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) > > > > > >
