WARN Error while fetching metadata with correlation id 1 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)

jms apache-kafka kafka-consumer-api jms-topic kafka-producer-api
Ratha picture Ratha · Apr 6, 2016 · Viewed 18.9k times · Source

when I run the following command with kafka 0.9.0.1 i get this warnings[1]. Can you please tell me what is wrong with my topics? (I'm talking to the kafka broker which runs in ec2)

#./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic MY_TOPIC?

[1] 

[2016-04-06 10:57:45,839] WARN Error while fetching metadata with correlation id 1 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)
[2016-04-06 10:57:46,066] WARN Error while fetching metadata with correlation id 3 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)
[2016-04-06 10:57:46,188] WARN Error while fetching metadata with correlation id 5 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)
[2016-04-06 10:57:46,311] WARN Error while fetching metadata with correlation id 7 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)

Answer

avr picture avr · Apr 6, 2016

You topic name is not valid because it has character '?' which is not legalCharacter for topic names.

Related questions

Monitoring UI for Apache kafka - kafka manager vs kafka monitor

I am new to kafka. We want to monitor and manage kafka topics. We tried different open source monitoring tools like kafka-monitor kafka-manager Both tools are good. But we are unable to make a decision which should be included in …

Read More
ActiveMQ vs Apollo vs Kafka

I don't have any previous experience with *MQs and I'm looking to build knowledge on JMS and message queues in general. That way, I wonder whether I should start with ActiveMQ or just "ignore" it altogether and start by teaching …

Read More
Is Apache Kafka another API for JMS?

Is not Apache Kafka another implementation of JMS? I am using JMS+AMQ in my application, and migrating to Apache Kafka. Do I have to change all JMS codes?

Read More