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

我需要在 kafka 类路径中安装 FileStreamSource 插件吗？我读到它与 kafka 捆绑在一起。

Answer 1

根据您安装 Kafka Connect 的方式，您可能需要在 worker 的配置中指定 plugin.path。

这是一个相关的问题： Kafka Connect failed to start