kafkaをJavaコードで使用する

Question

私は、Zookeeperで動作するKafkaインスタンスを持っています。私は実際にWindows上のコマンドラインを使用してプロデューサのコンシューマを作ることができます。プロデューサに文字列を書き、コンシューマに表示します。 私の目標は、JavaコードでKafkaを使ってファイル "転送"を実現することです。私はKafkaを使ってファイルを "読み込み"、次に "書き込む"ことを望みます。私が理解から

• FileStreamSinkConnector
• FileStreamSinkTask
• FileStreamSourceConnector
• FileStreamSourceTask

、SinkConnectorとTaksConnector：

は、これを実現するために、私は、このリポジトリで利用可能なコードを取りましたその間にファイルを書きますurceConnectorとSourceTaskはそれを読み取ります。

私の問題は、このコードをメインでどのように使用するのか、それをkafkaインスタンスでどのように使用するのか分かりません。

Answer 1

以前は、Kafkaコンソールのプロデューサーとコンシューマーを使用していました。あなたの質問に記載されているコネクタはKafka connectの一部です。here

ソースコネクタとシンクコネクタを使用するには、接続ワーカーを設定して起動する必要があります。スタンドアロンモードでプロセス全体を実行するには

Quick start pageには、これらのコネクタの使用方法が説明されています。