Kafka FileSteamSource Connect Fehler

Question

Ich versuche /tmp/my-test.txt mit kafka verbinden einen einfachen Text zu lesen. Unten ist meine Datei Quelleigenschaftendatei.

connect-file-source.properties 

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

Fehler, die ich erhalten, während die Arbeiter Anschluss Start: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches FileStreamSource

Benötige ich ein FileStreamSource Plugin im kafka Classpath zu installieren. Ich lese es kommt zusammen mit dem Kafka.

Answer 1

Je nachdem, wie Kafka Connect installiert haben, müssen Sie möglicherweise die plugin.path in der Arbeiter Konfiguration angeben.

Hier ist eine weitere Frage: Kafka Connect failed to start