Kafka Connect独立模式启动失败问题求助

问题背景 #

启动Kafka Connect独立模式时先后遇到两个错误：

1. 日志目录权限不足
2. 找不到FileStreamSource连接器类

用户配置与启动命令如下：

连接器配置（connect-file-source.properties） #

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

独立模式配置（connect-standalone.properties） #

bootstrap.servers=localhost:9092
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter.schemas.enable=true
offset.storage.file.filename=/tmp/connect.offsets

启动命令 #

$ bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties

第一个错误：日志权限不足 #

错误信息 #

log4j:ERROR setFile(null,true) call failed.
java.io.FileNotFoundException: /usr/local/kafka/bin/../logs/server.log (Permission denied)

解决方法 #

修改kafka-run-class.sh文件，添加日志目录环境变量：

export LOG_DIR=/var/log/kafka/

然后赋予日志目录足够权限（生产环境建议用更严格的权限配置，比如给kafka用户单独授权）：

chmod 777 /var/log/kafka/

第二个错误：找不到FileStreamSource连接器类 #

错误原因 #

FileStreamSource是Kafka自带的文件源连接器，但配置中只写了类名简写，必须指定完整全类名才能被正确加载。

解决步骤 #

1. 修改connect-file-source.properties中的connector.class配置，替换为完整类路径：

connector.class=org.apache.kafka.connect.file.FileStreamSource

2. 额外检查（可选）：

• 确认Kafka安装目录下libs/目录存在connect-file-<kafka-version>.jar文件（例如connect-file-3.6.1.jar）
• 如果自定义了plugin.path配置，确保该路径包含Kafka自带连接器的jar包目录（默认无需配置，独立模式会自动加载libs/下的连接器）

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