2
, когда я запускаю следующую команду с kafka 0.9.0.1, я получаю это предупреждение [1]. Не могли бы вы рассказать мне, что не так с моими темами? (Я говорю с Кафкой брокера, который работает в EC2)WARN Ошибка при извлечении метаданных с идентификатором корреляции 1: {MY_TOPIC? = INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)
#./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)
Теперь я пробовал без "?" и он не возвращает никаких сообщений. Это означает, что он застрял. Но когда я иду со старым потребительским инструментом, он потребляет сообщения. Можете ли вы рассказать мне причину? – Ratha
Старик, которого я пробовал ./kafka-console-consumer.sh --zookeeper zookeper.xx.com:2181 --topic MY_TOPIC - от начала – Ratha
Добавить ** - от начала ** флаг в конце вашей команды нового потребителя. Он должен работать. – avr