2017-05-17 3 views
0

Ich versuche, eine Datei mit Kafka Producer zu lesen. Zookeeper und Broker-Server laufen. Ich bin in der Lage Eingaben von Eingabeaufforderung unter Befehlen Kafka Hersteller und Verbraucher mit lesen -Kann nicht lesen von Datei über Kafka Produzent

Kafka Producer 
kafka-console-producer --topic incoming --broker localhost:9092 

Kafka Consumer 
kafka-console-consumer --topic incoming --zookeeper localhost:2181 

Zum Lesen aus der Datei i unter Befehlszeilenargumenten versucht hatte -

kafka-console-producer -–broker-list localhost:9092 -–topic incoming --new-producer < C:\abc.txt 

aber unterhalb Fehler erzeugt -

Ich googelte die Nachricht und es sagt über die Korrektur der Erzeugerbefehl, die für mich richtig aussieht.

+0

Was ist Ihre Kafka-Version? –

+0

seine kafka_2.11-0.10.0.0 –

+0

Der Befehl, den ich aus der Datei gelesen habe, ist es richtig? Ich benutzte (http://grokbase.com/t/kafka/users/157b71babg/kafka-producer-input-file), um es zu coniigure –

Antwort

0

Für kafka-10 müssen Sie nicht --new-producer flag übergeben. Der folgende Befehl funktioniert für mich:

kafka-console-producer.sh --broker-list localhost:9092 --topic incoming < C:\abc.txt 
+0

Ich muss noch den obigen Befehl treffen, um Wert für meinen Verbraucher zu erhalten. Nennt es das nicht selbst? –

+0

Ich hatte erwartet, dass es Daten holt, wenn die angegebene Datei aktualisiert wird. Wie können wir ein solches Verhalten erreichen? –

+0

In diesem Fall könnte Kafka-Connect Ihren Zweck erfüllen. Ich bin mir aber nicht 100% sicher. Siehe diesen Link: https://kafka.apache.org/quickstart#quickstart_kafkaconnect –

Verwandte Themen