Any error in the controller and state-change log? Also, 0.8.0 final is just released. Recommend that you try that version if possible.
Thanks, Jun On Thu, Dec 5, 2013 at 7:58 PM, 刘洋 <[email protected]> wrote: > Hi all, > > I got kafka.common.NotLeaderForPartitionException when trying to do this: > * kafka cluster test1 with 2 brokers: id=1,host=localhost,port=9091; and > id=2,host=localhost,port=9092; > * create topic:1001, with partition=0/1/2/3; replica=2; > * stop broker id=2; > * check kafka's zookeeper, topic-1001:partition-0 's node information is: > { "controller_epoch":15, "isr":[ 1 ], "leader":1, "leader_epoch":4, > "version":1 } > it seems leader/isr are broker id=1, that's right, but when I use > producer.send(topic:1001, partition:0) got the following exception ( I'm > using kafka_2.8.0-0.8.0-beta1): > > ______________________ > > 2013-12-06 09:58:45,471 [main] INFO kafka.producer.SyncProducer - > Connected to localhost:9091 for producing > 2013-12-06 09:58:45,472 [main] DEBUG > kafka.producer.async.DefaultEventHandler - Producer sent messages with > correlation id 11 for topics [10 > 01,1] to broker 1 on localhost:9091 > 2013-12-06 09:58:45,473 [main] WARN > kafka.producer.async.DefaultEventHandler - Produce request with > correlation id 11 failed due to [1001,1 > ]: kafka.common.NotLeaderForPartitionException > 2013-12-06 09:58:45,473 [main] INFO > kafka.producer.async.DefaultEventHandler - Back off for 100 ms before > retrying send. Remaining retries > = 0 > 2013-12-06 09:58:45,573 [main] INFO kafka.client.ClientUtils$ - Fetching > metadata from broker id:0,host:localhost,port:9091 with correlatio > n id 12 for 1 topic(s) Set(1001) > 2013-12-06 09:58:45,574 [main] DEBUG kafka.network.BlockingChannel - > Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 4 > 3690 (requested -1), SO_SNDBUF = 102400 (requested 102400). > 2013-12-06 09:58:45,574 [main] INFO kafka.producer.SyncProducer - > Connected to localhost:9091 for producing > 2013-12-06 09:58:45,577 [main] INFO kafka.producer.SyncProducer - > Disconnecting from localhost:9091 > 2013-12-06 09:58:45,577 [main] DEBUG kafka.client.ClientUtils$ - > Successfully fetched metadata for 1 topic(s) Set(1001) > 2013-12-06 09:58:45,577 [main] INFO kafka.producer.SyncProducer - > Disconnecting from localhost:9091 > 2013-12-06 09:58:45,579 [main] ERROR > kafka.producer.async.DefaultEventHandler - Failed to send requests for > topics 1001 with correlation ids > in [0,12] > > ________________________ > > and server.log of broker-1 said: > > [2013-12-06 11:22:05,754] ERROR [KafkaApi-1] Error while fetching metadata > for partition [1001,0] (kafka.server.KafkaApis) > kafka.common.ReplicaNotAvailableException > at > kafka.server.KafkaApis$$anonfun$17$$anonfun$20.apply(KafkaApis.scala:471) > at > kafka.server.KafkaApis$$anonfun$17$$anonfun$20.apply(KafkaApis.scala:456) > at > > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) > at > > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) > at > > scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) > at scala.collection.immutable.List.foreach(List.scala:45) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:206) > at scala.collection.immutable.List.map(List.scala:45) > at kafka.server.KafkaApis$$anonfun$17.apply(KafkaApis.scala:456) > at kafka.server.KafkaApis$$anonfun$17.apply(KafkaApis.scala:452) > at > > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) > at > > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) > at scala.collection.immutable.Set$Set1.foreach(Set.scala:81) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:206) > at scala.collection.immutable.Set$Set1.map(Set.scala:68) > at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:452) > at kafka.server.KafkaApis.handle(KafkaApis.scala:69) > at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) > at java.lang.Thread.run(Thread.java:662) > > thanks a lot! > _________________________________ > > Leo(刘洋) [email protected] > Email/Gtalk: [email protected]< > https://mail.xiaomi.com/owa/redir.aspx?C=mScpCrbpN06UGAlDjEdz_Dz3jwb0xNAIPL4A3R2_MzszQ9IWgwcmwpnVtu94MZ-nxilMjeZzMIk.&URL=mailto%3aleoyonn%40gmail.com > > > Miliao: 2481178 > Mobile: +86-138-118-20678 > _________________________________ >
