2
Wenn ich den folgenden Befehl mit kafka 0.9.0.1 ausführe, erhalte ich diese Warnungen [1]. Kannst du mir bitte sagen, was mit meinen Themen falsch ist? (Ich rede mit dem kafka Broker, die in EC2 läuft)WARN Fehler beim Abrufen von Metadaten mit der Korrelations-ID 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)
Jetzt habe ich ohne "?" und es gibt keine Nachrichten zurück. Das bedeutet, dass es feststeckt. Aber wenn ich mit älteren Verbraucher-Tool gehe, verbraucht es Nachrichten. Kannst du mir den Grund nennen? – Ratha
Ältere Verbraucher ich versuchte wie ./kafka-console-consumer.sh --zookekeeper zookeper.xx.com:2181 --topic MY_TOPIC --von Anfang – Ratha
Add ** - von Anfang an ** Flagge am Ende von Ihr neuer Verbraucher-Befehl. Es sollte funktionieren. – avr