0

メイン クラス org.apache.kafka.connect.cli.ConnectStandalone が見つからないか、読み込めませんでした kafka で connect-standalone を実行しようとすると、このエラーが発生します。

最初に、このファイルがある libexec に接続フォルダーがないことに気付き、それをダウンロードしました。それでも同じエラーです。

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

手動でいくつかダウンロードしようとしましたが、誰かが正しいフォルダを入手できる場所を教えてくれたら.

私がやりたいのは、csv を読み取り、それを 1 行ずつ消費者に送信する単純な kafka プロデューサーを作成することだけです。

少なくとも正しい方向に向かっているかどうか教えてください。

編集: 関連する場合は、brew を使用して kafka をダウンロードしました。

4

1 に答える 1

0

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

kafka borker が にlocalhost:9092、 zookeeper が にあると仮定するとlocalhost:2181、2 つのコンソールを開き、kafka ホームに移動します。

最初のコンソールでトピックを作成しますtest:

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

次に、そのコンソールでコンシューマーとして開きます。

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

2 番目のコンソールで、csv データをテスト トピックに送信します。

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

最初のコンソールで、消費された csv データを確認します。

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

于 2016-09-08T15:04:49.187 に答える