Kafka Connect Cluster不加载简单连接器插件
我尝试在连接群集中加载一个简单的 Kafka 连接器。我为连接器创建了jar，并将Kafka Connect作为docker启动。在日志中，我可以看到它正在加载插件。Docker 可以正确挂载 jar 文件。但是，在调用 http://localhost:8083/connector-plugins 时，我的自定义连接器不在列表中。
我简单地从这个repo:https://github.com/riferrei/kafka-source-connector.构建并启动了docker-compose，我的可用插件列表是:< code >[{"class":"io.confluent . connect . ActiveMQ . activemqsourceconnector "，" type":"source "，" version":"5.5.0"}，{ " class ":" io . confluent . connect . elasticsearch . elasticsearchsinkconnector "，" type":"sink "，" version":"5.5.0"}，{ " class ":" io . confluent "
有人知道连接器不在列表中会出现什么问题吗？或者提示我可以检查什么？
共有1个答案
问题出在 IntelliJ 配置中，我已经使用 IDE 启动了 mvn 命令，并且在项目语言级别设置为 Java 16。将其更改为 8 连接器（在 pom.xml 中匹配）后由 kafka 连接集群加载。
-
我想开发一个Kafka连接器，但为了快速测试，我想重新加载插件，而不是重新加载我的docker堆栈中的容器。有办法做到吗？ 实际上，我编译了连接器，并将jar文件移动到绑定在容器kafka connect上的文件夹中。移动文件后，我重新加载容器。 先谢谢你。
-
我正在windows计算机上使用Kafka，并尝试使用文件源连接器生成从文件到Kafka主题的内容。首先我启动了zookeeper，然后在启动Kafka Standalone Connector时启动了Kafka server（步骤3），我收到了很多警告，ReflectionsException 我对此没有什么疑问： 1。我需要添加一些jar文件吗 2。在libs文件夹下的Kafka dir中有一
-
我有一个现有的2个kafka服务器加载了mysql连接器。它起作用了。此外，我需要添加MongoDB连接器。我已经在我的Kafka服务器（Centos7）上安装了confluent schema registry，它可以工作，我停止/启动/重新启动，看起来没有什么问题。我在这里下载并提取了debezium Mongo插件/usr/连接器/插件/debezium连接器mongodb/ 我编辑了 /e
-
我下载了aiven kafka connect jdbc并手动构建了jar。将同一个jar放在kafka connect插件目录中，并在connect-standalone.properties中提到插件路径。但当我运行connect时，它会抛出一个错误：“找不到任何实现连接器的类，并且名称与io.aivn.connect.JdbcSourceConnector匹配” 我的配置中缺少什么？ 连接-
-
我有一个9个波段的多光谱数据集。由于数据非常大，我将每个波段拆分为256 x 256个样本。所以我每个波段有16个这样的样本，我把它们保存在不同的文件夹里。现在我如何连接9条带的每个样本？ 例如，我想将来自第一波段数据的第一个样本与第二波段的第一个样本、第三波段的第一个样本连接起来，直到第九波段。然后是第1，第2...第9带的第2个样品。如此直到第16个样品。
-
本文向大家介绍简单谈谈mysql左连接内连接，包括了简单谈谈mysql左连接内连接的使用技巧和注意事项，需要的朋友参考一下 前言 最近忙着开发x省冷链追溯系统，天天干到晚上十一点多才回到家，周末也加班，没啥时间写博客，闲下来再好好写写 业务： sql语句统计出入库数据。 问题： 只统计了X端入库单。 原因： 没有发现X端的数据库中只有入库单是有a字段数据而出库单是没有的，并使用了a字段去inner