Kafka Connect独立模式启动失败：找不到FileStreamSource连接器

问题描述 #

执行Kafka Connect standalone模式启动脚本，通过FileStreamSource连接器读取日志文件发送到Kafka主题时启动失败，报错无法找到匹配FileStreamSource的Connector实现类。

执行命令：

/opt/kafka/bin/connect-standalone.sh \
    retail_logs_standalone.properties \
    retail_logs_file_source.properties

源连接器配置（retail_logs_file_source.properties）：

name=dee-retail-file-source
connector.class=FileStreamSource
tasks.max=1
file=/opt/gen_logs/logs/access.log
topic=dee_retail

原因分析 #

FileStreamSource是Kafka官方提供的测试用连接器，在Kafka 2.0及以上版本中，它默认不会自动加载到Connect的类路径中，仅使用短类名FileStreamSource会导致Connect无法定位到对应的实现类。此外，若standalone配置中未正确指定插件路径，也会导致自带连接器无法被识别。

解决方案 #

方案1：使用全限定类名替换短类名 #

直接在连接器配置中指定FileStreamSource的全类名，让Connect可以准确定位到实现类：

修改后的retail_logs_file_source.properties：

name=dee-retail-file-source
connector.class=org.apache.kafka.connect.file.FileStreamSource
tasks.max=1
file=/opt/gen_logs/logs/access.log
topic=dee_retail

方案2：配置plugin.path加载自带连接器 #

在retail_logs_standalone.properties中添加或修改plugin.path配置，指向Kafka安装目录下的自带连接器目录：

plugin.path=/opt/kafka/share/java

该目录包含Kafka所有自带连接器的jar包（包括kafka-connect-file相关jar），配置后Connect会自动扫描并加载这些连接器。

验证步骤 #

1. 按上述任一方案修改配置后，重新执行启动命令
2. 查看Connect日志，确认无"找不到Connector类"的报错
3. 若Connect默认端口（8083）未修改，可通过以下命令验证连接器是否成功注册：

curl localhost:8083/connectors

返回结果中应包含dee-retail-file-source。

内容的提问来源于stack exchange，提问作者Oyindamola Victor