WARNEN Fehler beim abrufen von Metadaten mit Korrelations-id 1 : {MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.Kunden.NetworkClient)

wenn ich den folgenden Befehl mit kafka 0.9.0.1 bekomme ich diese Warnungen[1]. Können Sie mir bitte sagen, was ist falsch mit meinen Themen? (Ich spreche auf die kafka-broker, die 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)
InformationsquelleAutor Ratha | 2016-04-06
  1. 5

    Sie Thema-name ist nicht gültig, weil es ein Zeichen '?' ist nicht legalCharacter zum Thema Namen.

    • Jetzt habe ich versucht, ohne "?" und es ist nicht wieder alle Nachrichten. Das bedeutet, dass es blieb. Aber wenn ich mit älteren Verbraucher, tool, it-Nachrichten verbraucht. Können Sie mir sagen, der Grund?
    • Ältere Verbraucher habe ich versucht wie ./kafka-console-consumer.sh --Tierpfleger zookeper.xx.com:2181 --Thema MY_TOPIC-von-Anfang
    • Fügen Sie - von-Anfang - flag am Ende der new-Verbraucher-Befehl. Es sollte funktionieren.
    • Nein es funktioniert nicht..Es stecken..überprüfen Sie Bitte folgende threads an apache kafka-user-list //gibt es irgendwelche Verhaltensänderungen zu verbinden lokale server und remote server?// und /Consumer-thread wird ewig warten, nicht wieder alle Objekte//
    • Es wäre toll, wenn du mir den Grund
    • Beim ausführen der Verbraucher-Befehl mit - von-Anfang Flagge, dann ist es zurückgesetzt Verbraucher offset zum kleinsten(frühestens) und verbraucht alle vorhandenen Nachrichten in Thema in der Erwägung, dass der Befehl mit sich, dass flag verbrauchen wird vom größten(aktuellen) versetzt.
    • ok..also zurück zu meiner ursprünglichen Frage. Jetzt ist der poll() stecken, für immer, ohne jede Ausnahme zu meinem neuen Verbraucher. Aber meine ec2-Instanz, die Einstellungen sehen gut aus
    • Ratha, hast du jemals herausfinden, warum poll() stecken? Ich sehe ähnliches Verhalten auf meinem lokalen Instanz.

    InformationsquelleAutor avr
  2. 0

    es passiert, wenn unser Produzent ist nicht in der Lage zu produzieren, um die entsprechende Adresse Bitte check-in /kafka/config/server.Eigenschaften, die den Wert der beworbenen Zuhörer,
    wenn Ihr kommentiert , gibt es andere Probleme.
    Aber falls nicht, setzen Sie bitte Ihre ip-Adresse anstelle von localhost und dann neu starten, die beiden Tierpfleger und kafka
    Starten Sie die Konsole Produzent hoffentlich wird es funktionieren.

    InformationsquelleAutor A.s
Schreibe einen Kommentar