Kafka：连接器的插件类加载器错误：“org”。阿帕奇。Kafka。连接文件找不到FileStreamSourceConnector
我正在windows计算机上使用Kafka，并尝试使用文件源连接器生成从文件到Kafka主题的内容。首先我启动了zookeeper，然后在启动Kafka Standalone Connector时启动了Kafka server（步骤3），我收到了很多警告，ReflectionsException
我对此没有什么疑问：
1。我需要添加一些jar文件吗
2。在libs文件夹下的Kafka dir中有一些jar文件，我需要将它们添加到类路径吗？
任何线索都将不胜感激。
共有1个答案
我认为您可以忽略有关类加载器的消息。
真正的错误消息是找不到您的文件
修复批处理脚本中Java变量的引用有一些JIRA问题，这将修复类路径和jar查找问题，但正如我所评论的，最好使用生产级日志转发器将文件读取到Kafka
-
我想开发一个Kafka连接器，但为了快速测试，我想重新加载插件，而不是重新加载我的docker堆栈中的容器。有办法做到吗？ 实际上，我编译了连接器，并将jar文件移动到绑定在容器kafka connect上的文件夹中。移动文件后，我重新加载容器。 先谢谢你。
-
我尝试在连接群集中加载一个简单的 Kafka 连接器。我为连接器创建了jar，并将Kafka Connect作为docker启动。在日志中，我可以看到它正在加载插件。Docker 可以正确挂载 jar 文件。但是，在调用 http://localhost:8083/connector-plugins 时，我的自定义连接器不在列表中。 我简单地从这个repo:https://github.com/r
-
我正在尝试使用Kafka Connect Elasticsearch连接器，但没有成功。它正在崩溃，并出现以下错误： 我已经在kafka子文件夹中解压了插件的编译版本，并在connect-standalone.properties中有以下代码行: 我可以看到该文件夹中的各种连接器，但Kafka Connect不加载它们；但它确实加载了标准连接器，如下所示： 如何正确注册连接器？
-
下面是/etc/kafka/connect-MongoDB-source.properties中的MongoDB配置 但是低于误差 以独立模式运行连接器。 我在debezium-debezium-连接器-mongob-1.0.0/debezium-connector-mongodb-1.0.0.Final.jar 类路径的设置如下 使用插件路径，我看到它能够注册和加载所有必需的插件。 但最后还是同
-
我对Kafka connect很陌生。我想把我的信息从Kafka主题推到弹性搜索。在阅读了可用的文档之后，我从发行版tar下载并编译了弹性搜索接收器。拉链(https://github.com/confluentinc/kafka-connect-elasticsearch/releases) 我添加了弹性搜索属性文件，并将上述jar包含在类路径中。当我在独立模式下运行kafka connect时
-
我对flink/Java/Scala还比较陌生，所以这可能不是问题，但非常感谢您的帮助。我还没有找到一个将Flink Kafka连接器与Flink 1.13结合使用的示例（对我适用）。 我的项目在这里：https://github.com/sysarcher/flink-scala-tests 我想我无法使用我想试用的FlinkKafkaConsumer（链接）。 我正在使用IntelliJ Id