Kafkaがスタンドアロンで接続 - メインクラスを見つけられないかロードできませんでした。org.apache.kafka.connect.cli.ConnectStandalone

Question

メインクラスを見つけたりロードできませんでした。org.apache.kafka.connect.cli.ConnectStandalone 私がkafkaでconnect-standaloneを実行しようとします。

まず、私はこのファイルがあった場所のlibexecに接続フォルダがないことに気付きました。ダウンロードしました。それでも同じエラー。

私は別々にConnectStandalone.javaファイルをコンパイルしようとしましたが、kafkaのフォルダからたくさんのパッケージが見つからないことがわかりました。 org/apache/kafkaにはいくつかのパッケージとの接続と共通フォルダがあるはずですが、そうではありませんでした。 パッケージorg.slf4jもありません。

手動でいくつかダウンロードしようとしましたが、どこから正しいフォルダを入手できるか教えてもらえますか？

私がしたいのは、csvを読み込んでそれをコンシューマに1行ずつ送る単純なカフカプロデューサを作成することです。

私が正しい方向に向いているかどうか教えてください。

EDIT：kafkaをダウンロードするには、brewを使用してください（該当する場合）。

Answer 1

kafkaインストールには不完全なバイナリがあるようです。プロデューサのcsvファイルを持つこと。 Linuxマシンからサンプルのものを実行することができます。そのコンソールによって消費者として

bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 1 --replication-factor 1 

その後オープン：

と仮定すると、カフカのborkerは、最初のコンソールで

トピックtestを作成し、localhost:2181でlocalhost:9092と飼育係にあるオープン2コンソールとカフカの家に行きます：第2コンソール送信CSVデータで

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test 

トピックをテストする：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test < abc.csv 

最初のコンソールで消費されたcsvデータを参照してください。

上記のコマンドも実行していない場合は、kafkaとzookeeperを再インストールする必要があります。