All,
Please help...
I constantly get LeaderNotAvailableExceptions using the
kafka-console-producer.
I am using kafka_2.8.0-0.8.0
zookeeper and kafka-server seem to run without errors.
Here are the results from the topic list and the kafka-console-producer.
The server-change.log is below; there are not errors.
c:\kafka>.\bin\windows\kafka-list-topic.bat --zookeeper localhost:2181
topic: bob partition: 0 leader: 0 replicas: 0 isr: 0
topic: bob partition: 1 leader: 0 replicas: 0 isr: 0
c:\kafka>.\bin\windows\kafka-console-producer.bat --broker-list
localhost:9092 -
-topic bob
aaaaaaaaaaaaaaaaaaaaaaaa
[2014-03-21 20:17:26,093] WARN Error while fetching metadata
[{TopicMetadata for
topic bob ->
No partition metadata for topic bob due to
kafka.common.LeaderNotAvailableExcept
ion}] for topic [bob]: class kafka.common.LeaderNotAvailableException (
kafka.pr
oducer.BrokerPartitionInfo)
[2014-03-21 20:17:26,110] WARN Error while fetching metadata
[{TopicMetadata for
topic bob ->
No partition metadata for topic bob due to
kafka.common.LeaderNotAvailableExcept
ion}] for topic [bob]: class kafka.common.LeaderNotAvailableException (
kafka.pr
oducer.BrokerPartitionInfo)
[2014-03-21 20:17:26,111] ERROR Failed to collate messages by topic,
partition d
ue to: Failed to fetch topic metadata for topic: bob
(kafka.producer.async.Defau
ltEventHandler)
bbbbbbbbbbbbbbbbbbbbb
cccccccccccccccccccc
ddddddddddddddddddd
server-change.log
[2014-03-21 20:15:27,806] DEBUG preRegister called.
Server=com.sun.jmx.mbeanserver.JmxMBeanServer@31a9dc55,
name=log4j:logger=state.change.logger (state.change.logger)
[2014-03-21 20:17:26,043] TRACE Controller 0 epoch 1 changed partition
[bob,1] state from NotExists to New with assigned replicas 0
(state.change.logger)
[2014-03-21 20:17:26,057] TRACE Controller 0 epoch 1 changed partition
[bob,0] state from NotExists to New with assigned replicas 0
(state.change.logger)
[2014-03-21 20:17:26,066] TRACE Controller 0 epoch 1 changed state of
replica 0 for partition [bob,1] to NewReplica (state.change.logger)
[2014-03-21 20:17:26,067] TRACE Controller 0 epoch 1 changed state of
replica 0 for partition [bob,0] to NewReplica (state.change.logger)
[2014-03-21 20:17:26,092] TRACE Controller 0 epoch 1 changed partition
[bob,1] from OnlinePartition to OnlinePartition with leader 0
(state.change.logger)
[2014-03-21 20:17:26,099] TRACE Controller 0 epoch 1 changed partition
[bob,0] from OnlinePartition to OnlinePartition with leader 0
(state.change.logger)
[2014-03-21 20:17:26,105] TRACE Controller 0 epoch 1 sending become-leader
LeaderAndIsr request with correlationId 6 to broker 0 for partition [bob,1]
(state.change.logger)
[2014-03-21 20:17:26,106] TRACE Controller 0 epoch 1 sending become-leader
LeaderAndIsr request with correlationId 6 to broker 0 for partition [bob,0]
(state.change.logger)
[2014-03-21 20:17:26,110] TRACE Controller 0 epoch 1 sending UpdateMetadata
request with correlationId 6 to broker 0 for partition [bob,1]
(state.change.logger)
[2014-03-21 20:17:26,110] TRACE Controller 0 epoch 1 sending UpdateMetadata
request with correlationId 6 to broker 0 for partition [bob,0]
(state.change.logger)
[2014-03-21 20:17:26,112] TRACE Controller 0 epoch 1 changed state of
replica 0 for partition [bob,1] to OnlineReplica (state.change.logger)
[2014-03-21 20:17:26,113] TRACE Controller 0 epoch 1 changed state of
replica 0 for partition [bob,0] to OnlineReplica (state.change.logger)
[2014-03-21 20:17:26,121] TRACE Broker 0 handling LeaderAndIsr request
correlation id 6 received from controller 0 epoch 1 for partition [bob,1]
(state.change.logger)
[2014-03-21 20:17:26,122] TRACE Broker 0 handling LeaderAndIsr request
correlation id 6 received from controller 0 epoch 1 for partition [bob,0]
(state.change.logger)
[2014-03-21 20:17:26,126] TRACE Broker 0 received LeaderAndIsr request
correlationId 6 from controller 0 epoch 1 starting the become-leader
transition for partition [bob,1] (state.change.logger)
[2014-03-21 20:17:26,179] TRACE Broker 0 completed become-leader transition
for partition [bob,1] (state.change.logger)
[2014-03-21 20:17:26,179] TRACE Broker 0 handled LeaderAndIsr request
correlationId 6 received from controller 0 epoch 1 for partition [bob,1]
(state.change.logger)
[2014-03-21 20:17:26,179] TRACE Broker 0 received LeaderAndIsr request
correlationId 6 from controller 0 epoch 1 starting the become-leader
transition for partition [bob,0] (state.change.logger)
[2014-03-21 20:17:26,185] TRACE Broker 0 completed become-leader transition
for partition [bob,0] (state.change.logger)
[2014-03-21 20:17:26,185] TRACE Broker 0 handled LeaderAndIsr request
correlationId 6 received from controller 0 epoch 1 for partition [bob,0]
(state.change.logger)
[2014-03-21 20:17:26,200] TRACE Controller 0 epoch 1 received response
correlationId 6 for a request sent to broker 0 (state.change.logger)
[2014-03-21 20:17:26,209] TRACE Broker 0 cached leader info
(LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:0)
for partition [bob,1] in response to UpdateMetadata request sent by
controller 0 epoch 1 with correlation id 6 (state.change.logger)
[2014-03-21 20:17:26,210] TRACE Broker 0 cached leader info
(LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:0)
for partition [bob,0] in response to UpdateMetadata request sent by
controller 0 epoch 1 with correlation id 6 (state.change.logger)
[2014-03-21 20:17:26,212] TRACE Controller 0 epoch 1 received response
correlationId 6 for a request sent to broker 0 (state.change.logger)
--
Bob Zitelli
201-390-8537
robert.zite...@gmail.com
