Kafka FileSteamSource接続エラー

Question

kafka connectを使用して、単純なテキスト/tmp/my-test.txtを読み込もうとしています。以下は私のファイルソースプロパティファイルです。コネクタワーカーを開始しながら、私が手

connect-file-source.properties 

name=local-file-source 
connector.class=FileStreamSource 
tasks.max=1 
file=/tmp/my-test.txt 
topic=my-connect-test 

エラー：org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches FileStreamSource

iはカフカのクラスパスにFileStreamSourceプラグインをインストールする必要があります。私はそれがカフカにバンドルされて読んでいます。

Answer 1

Kafka Connectのインストール方法によっては、ワーカーの設定でplugin.pathを指定する必要があります。

ここに関連する質問があります。 Kafka Connect failed to start