我正在尝试使用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 我需要在kafka类路径中安装filestreamsource插件吗。我读到它和Kafka捆绑在一起。