1,first try to produce topici 'ximi' in server3 (kafka server)
[root@server3 kafka_2.8.0-0.8.0]# bin/kafka-console-producer.sh --broker-list
server3:9092 --topic ximi
ximi gest
[2014-01-18 10:57:04,250] WARN Error while fetching metadata [{TopicMetadata
for topic ximi ->
No partition metadata for topic ximi due to
kafka.common.LeaderNotAvailableException}] for topic [ximi]: class
kafka.common.LeaderNotAvailableException (kafka.producer.BrokerPartitionInfo)
[2014-01-18 10:57:04,272] WARN Error while fetching metadata [{TopicMetadata
for topic ximi ->
No partition metadata for topic ximi due to
kafka.common.LeaderNotAvailableException}] for topic [ximi]: class
kafka.common.LeaderNotAvailableException (kafka.producer.BrokerPartitionInfo)
[2014-01-18 10:57:04,273] ERROR Failed to collate messages by topic, partition
due to: Failed to fetch topic metadata for topic: ximi
(kafka.producer.async.DefaultEventHandler)
test new me
hello
2, Second try to consume...
[root@server3 kafka_2.8.0-0.8.0]# bin/kafka-console-consumer.sh --zookeeper
server3:3181 --topic ximi --from-beginning
[2014-01-18 10:57:59,971] WARN
[console-consumer-65386_server3-1390013879485-3f815f14], no brokers found when
trying to rebalance. (kafka.consumer.ZookeeperConsumerConnector)
3, Third, surprisingly I can find the topic in kafka topic list.
[root@server3 kafka_2.8.0-0.8.0]# bin/kafka-list-topic.sh --zookeeper
server2:3181
topic: test partition: 0 leader: 2 replicas: 2 isr: 2
topic: ximi partition: 0 leader: 2 replicas: 2 isr: 2
topic: xp partition: 0 leader: 2 replicas: 2 isr: 2
