2017-05-17 10 views
0

kafka producer.ZookeeperとBrokerサーバを使用してファイルを読み取ろうとしています。Kafkaプロデューサ経由でファイルから読み取ることができません

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

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

ファイルからの読み込みのために、私は、コマンドライン引数の下にしようとした - - 私は、コマンドの下に使用してカフカのプロデューサーを使用して、コマンドプロンプトからの入力と消費者を読み取ることができています

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

が、それは誤りを下回る生産しました -

û is not a recognized option 

私はメッセージを拾って、私に正しいと思われるプロデューサコマンドを修正すると述べています。

+0

あなたのカフカバージョンは何ですか? –

+0

そのkafka_2.11-0.10.0.0 –

+0

ファイルから読み込みに使用したコマンドは正しいですか?私はそれをconfiigureに(http://grokbase.com/t/kafka/users/157b71babg/kafka-producer-input-file)を使用 –

答えて

0

kafka-10の場合、 - new-producerフラグを渡す必要はありません。次のコマンドは私のために働いています:

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

私はまだ私の消費者のための価値を得るために上記のコマンドをヒットする必要があります。それはそれを自分でそれを呼び出すことはありませんか? –

+0

私は、指定されたファイルが更新されるたびにデータを取得することを期待していました。どのようにしてこのような行動を達成できますか? –

+0

その場合、kafka-connectがあなたの目的に役立つかもしれないと思います。私は100%確実ではない。このリンクを参照してください:https://kafka.apache.org/quickstart#quickstart_kafkaconnect –

関連する問題