[
https://issues.apache.org/jira/browse/KAFKA-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira resolved KAFKA-2152.
---------------------------------
Resolution: Not A Problem
> Console producer fails to start when server running with broker.id != 0
> -----------------------------------------------------------------------
>
> Key: KAFKA-2152
> URL: https://issues.apache.org/jira/browse/KAFKA-2152
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.8.2.1
> Reporter: Lior Gonnen
> Priority: Critical
>
> Scenario to reproduce:
> 1. Start zookeeper as usual: bin/zookeeper-server-start.sh
> config/zookeeper.properties
> 2. Start local server as usual: bin/kafka-server-start.sh
> config/server.properties
> 3. Start console producer: bin/kafka-console-producer.sh --broker-list
> localhost:9092 --topic test
> 4. Producer starts as usual, and allows sending messages
> 5. Stop the producer and server
> 6. In config/server.properties, change broker.id to 2 (or any other non-zero
> number)
> 7. Repeat steps 2 and 3
> 8. The received output is as follows:
> [2015-04-26 20:00:47,571] WARN Error while fetching metadata partition 0
> leader: none replicas: isr: isUnderReplicated: false for topic
> partition [test,0]: [class kafka.common.LeaderNotAvailableException]
> (kafka.producer.BrokerPartitionInfo)
> [2015-04-26 20:00:47,575] WARN Failed to collate messages by topic,partition
> due to: No leader for any partition in topic test
> (kafka.producer.async.DefaultEventHandler)
> [2015-04-26 20:00:47,682] WARN Error while fetching metadata partition 0
> leader: none replicas: isr: isUnderReplicated: false for topic
> partition [test,0]: [class kafka.common.LeaderNotAvailableException]
> (kafka.producer.BrokerPartitionInfo)
> [2015-04-26 20:00:47,682] WARN Failed to collate messages by topic,partition
> due to: No leader for any partition in topic test
> (kafka.producer.async.DefaultEventHandler)
> [2015-04-26 20:00:47,789] WARN Error while fetching metadata partition 0
> leader: none replicas: isr: isUnderReplicated: false for topic
> partition [test,0]: [class kafka.common.LeaderNotAvailableException]
> (kafka.producer.BrokerPartitionInfo)
> [2015-04-26 20:00:47,790] WARN Failed to collate messages by topic,partition
> due to: No leader for any partition in topic test
> (kafka.producer.async.DefaultEventHandler)
> [2015-04-26 20:00:47,897] WARN Error while fetching metadata partition 0
> leader: none replicas: isr: isUnderReplicated: false for topic
> partition [test,0]: [class kafka.common.LeaderNotAvailableException]
> (kafka.producer.BrokerPartitionInfo)
> [2015-04-26 20:00:47,897] WARN Failed to collate messages by topic,partition
> due to: No leader for any partition in topic test
> (kafka.producer.async.DefaultEventHandler)
> [2015-04-26 20:00:48,002] WARN Error while fetching metadata partition 0
> leader: none replicas: isr: isUnderReplicated: false for topic
> partition [test,0]: [class kafka.common.LeaderNotAvailableException]
> (kafka.producer.BrokerPartitionInfo)
> [2015-04-26 20:00:48,004] ERROR Failed to send requests for topics test with
> correlation ids in [0,8] (kafka.producer.async.DefaultEventHandler)
> [2015-04-26 20:00:48,004] ERROR Error in handling batch of 1 events
> (kafka.producer.async.ProducerSendThread)
> kafka.common.FailedToSendMessageException: Failed to send messages after 3
> tries.
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:594)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at
> kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
