Kafka Connect Cluster 不加载简单的连接器插件
Kafka Connect Cluster does not load simple connector plugin
我尝试在 Connect Cluster 中加载一个简单的 Kafka 连接器。
我为连接器创建了 jar，并以 docker 的形式启动了 Kafka Connect。在日志中，我可以看到它正在加载插件。 Docker 正确挂载 jar 文件。
但是，当调用 http://localhost:8083/connector-plugins 时，我的自定义连接器不在列表中。
我已经简单地构建并开始 docker-compose 从这个 repo：https://github.com/riferrei/kafka-source-connector。
我拥有的可用插件列表是：
[{"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.connect.ibm.mq.IbmMQSourceConnector","type":"source","version":"5.5.0"},{"class":"io.confluent.connect.jdbc.JdbcSinkConnector","type":"sink","version":"5.5.0"},{"class":"io.confluent.connect.jdbc.JdbcSourceConnector","type":"source","version":"5.5.0"},{"class":"io.confluent.connect.jms.JmsSourceConnector","type":"source","version":"5.5.0"},{"class":"io.confluent.connect.s3.S3SinkConnector","type":"sink","version":"5.5.0"},{"class":"io.confluent.connect.storage.tools.SchemaSourceConnector","type":"source","version":"5.5.0-ccs"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type":"sink","version":"5.5.0-ccs"},{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","type":"source","version":"5.5.0-ccs"},{"class":"org.apache.kafka.connect.mirror.MirrorCheckpointConnector","type":"source","version":"1"},{"class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector","type":"source","version":"1"},{"class":"org.apache.kafka.connect.mirror.MirrorSourceConnector","type":"source","version":"1"}]
有谁知道连接器不在列表中可能是什么问题？或者提示我可以检查什么？
问题出在 IntelliJ 配置中，我已经使用 IDE 启动了 mvn 命令，并且项目语言级别设置为 Java 16。
将其更改为 8 个连接器后（在 pom.xml 中匹配）由 kafka connect 集群加载。
我尝试在 Connect Cluster 中加载一个简单的 Kafka 连接器。 我为连接器创建了 jar，并以 docker 的形式启动了 Kafka Connect。在日志中，我可以看到它正在加载插件。 Docker 正确挂载 jar 文件。 但是，当调用 http://localhost:8083/connector-plugins 时，我的自定义连接器不在列表中。
我已经简单地构建并开始 docker-compose 从这个 repo：https://github.com/riferrei/kafka-source-connector。
我拥有的可用插件列表是：
[{"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.connect.ibm.mq.IbmMQSourceConnector","type":"source","version":"5.5.0"},{"class":"io.confluent.connect.jdbc.JdbcSinkConnector","type":"sink","version":"5.5.0"},{"class":"io.confluent.connect.jdbc.JdbcSourceConnector","type":"source","version":"5.5.0"},{"class":"io.confluent.connect.jms.JmsSourceConnector","type":"source","version":"5.5.0"},{"class":"io.confluent.connect.s3.S3SinkConnector","type":"sink","version":"5.5.0"},{"class":"io.confluent.connect.storage.tools.SchemaSourceConnector","type":"source","version":"5.5.0-ccs"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type":"sink","version":"5.5.0-ccs"},{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","type":"source","version":"5.5.0-ccs"},{"class":"org.apache.kafka.connect.mirror.MirrorCheckpointConnector","type":"source","version":"1"},{"class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector","type":"source","version":"1"},{"class":"org.apache.kafka.connect.mirror.MirrorSourceConnector","type":"source","version":"1"}]
有谁知道连接器不在列表中可能是什么问题？或者提示我可以检查什么？
问题出在 IntelliJ 配置中，我已经使用 IDE 启动了 mvn 命令，并且项目语言级别设置为 Java 16。 将其更改为 8 个连接器后（在 pom.xml 中匹配）由 kafka connect 集群加载。