2015-11-29 8 views
6

habe ich versucht, sowohl Kafka 0.8.2.2 und 0.9.0.0 und bin das gleiche Problem auf beiden zu sehen, was das ist:Kafka Verbraucher erhalten keine Nachrichten, bis neu gestartet

ich einen frischen Zookeeper und Kafka-Server starten (leere Daten/Log-Verzeichnisse), starte den Consumer-Prozess für "mytopic", starte den Producer-Prozess für "mytopic" und sende dann eine Nachricht über Producer. Der Benutzer erhält die Nachricht erst nach einem Neustart.

Ich habe versucht, den Verbraucher mit "frühesten" und "neuesten" Consumer-Offset-Reset-Strategien zu konfigurieren.

Meine Frage ist - ist das erwartete Verhalten? Wenn ja, gibt es eine Möglichkeit, es zu ändern. Wenn nicht, was geht hier vor?

+0

Können Sie Befehle teilen, die Sie bereitstellen, oder einen Code? – usman

+0

Verwenden Sie die Befehlszeilen-Clients zum Starten von Produzenten und Konsumenten? An welchem ​​Punkt beginnst du den Producer und Consumer in Bezug auf die Erstellung des Themas? – morganw09dev

+0

Interessante Frage. aber brauchen mehr Details. – BAE

Antwort

-1

Wenn Sie den Consumer zuerst mit einem Thema starten, das noch nicht existiert, aber vom Kafka-Broker automatisch erstellt wird, kann dies das gleiche Verhalten wie in this question sein. Können Sie versuchen, ob die dort erwähnte Lösung Ihr Problem löst?

Verwandte Themen