ファイルからデータを読み取るために公式ドキュメントに従って実装しています。kakf-connect
私はカフカを完全に実行しています。メッセージを送受信するプロデューサーとコンシューマー。
ただし、次のコマンドを実行すると:
sudo ./bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties
次のエラーが表示されます。
エラー: メイン クラス org.apache.kafka.connect.cli.ConnectStandalone が見つからないか、読み込めませんでした
チェックを入れたところ、ファイルConnectStandalone hereがありますconnect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone。
私のconnect-file-source.propertiesは次のとおりです。
name=local-file-source
connector.class=org.apache.kafka.connect.file.FileStreamSourceConnector
tasks.max=1
file=test.txt
topic=spark-kafka
何か足りないものはありますか？このエラーを取り除くにはどうすればよいですか?