java - Kafka：错误连接器的插件类加载器：找不到'org.apache.kafka.connect.file.FileStreamSourceConnector'

Question

我在 Windows 机器上使用 Kafka，我正在尝试使用文件源连接器将内容从文件生成到 Kafka 主题。首先，我在启动 Kafka Standalone Connector 时启动了 zookeeper，然后启动了 Kafka 服务器（在第 3 步），我收到了很多 WARNING、ReflectionsException 和 Error 日志。

我这里有几个疑问：
1.我需要添加一些jar文件吗？
2.在libs文件夹下的Kafka目录中有一些jar文件，我需要将它们添加到类路径中吗？

任何线索将不胜感激。

标签： javaapache-kafkaapache-kafka-connect

Answer 1

我认为您可以忽略有关类加载器的消息。

真正的错误信息是找不到您的文件

关于修复批处理脚本中围绕 Java 变量的引用存在一些 JIRA 问题，这将修复类路径和 jar 查找问题，但正如我评论的那样，最好使用生产级日志转发器将文件读取到 Kafka