Hi,
I wrote a java client to send data from file to kafka,(this code worked
when ran in local)
got following error
$ java -cp kafka-0.0.1-SNAPSHOT.jar KafkaProducerFromFile
[2016-05-04 03:39:24,996] ERROR Failed to collate messages by topic,
partition due to: Failed to fetch topic metadata for topic: test
(kafka.producer.async.DefaultEventHandler:97)
[2016-05-04 03:39:25,102] ERROR Failed to collate messages by topic,
partition due to: Failed to fetch topic metadata for topic: test
(kafka.producer.async.DefaultEventHandler:97)
[2016-05-04 03:39:25,209] ERROR Failed to collate messages by topic,
partition due to: Failed to fetch topic metadata for topic: test
(kafka.producer.async.DefaultEventHandler:97)
[2016-05-04 03:39:25,315] ERROR Failed to collate messages by topic,
partition due to: Failed to fetch topic metadata for topic: test
(kafka.producer.async.DefaultEventHandler:97)
[2016-05-04 03:39:25,419] ERROR Failed to send requests for topics test
with correlation ids in [0,8] (kafka.producer.async.DefaultEventHandler:97)
Exception in thread "main" kafka.common.FailedToSendMessageException:
Failed to send messages after 3 tries.
at
kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:91)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at .KafkaProducerFromFile.main(KafkaProducerFromFile.java:40)
$
Then tried running console producer
got
$ ./bin/kafka-console-producer.sh --topic test --broker-list localhost:6667
hello
[2016-05-04 03:54:32,037] WARN Error while fetching metadata with
correlation id 0 : {test=TOPIC_AUTHORIZATION_FAILED}
(org.apache.kafka.clients.NetworkClient)
[2016-05-04 03:54:32,133] WARN Error while fetching metadata with
correlation id 1 : {test=TOPIC_AUTHORIZATION_FAILED}
(org.apache.kafka.clients.NetworkClient)
[2016-05-04 03:54:32,235] WARN Error while fetching metadata with
correlation id 2 : {test=TOPIC_AUTHORIZATION_FAILED}
(org.apache.kafka.clients.NetworkClient)
[2016-05-04 03:54:32,337] WARN Error while fetching metadata with
correlation id 3 : {test=TOPIC_AUTHORIZATION_FAILED}
(org.apache.kafka.clients.NetworkClient)
....
Can someone help me with this
Thanks.
