You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Confluent Kafka Connect无法加载自定义HttpSinkConnector的问题求助

Confluent Kafka Connect无法加载自定义HttpSinkConnector的问题求助

大家好,我最近在本地部署Confluent Kafka后,遇到了自定义连接器加载异常的问题,想请教下社区的朋友们:

我是在Mac上完成Confluent Kafka安装的,现在尝试通过JAR包给本地Kafka Connect添加自定义连接器,但发现部分连接器无法正常加载。

我的操作步骤:

  1. 把自定义连接器模块打包成JAR文件,复制到路径/opt/confluent-5.1.0/share/confluent-hub-components下;
  2. 更新connect-distributed.properties配置文件中的plugin.path,设置为:
plugin.path=/opt/confluent-5.1.0/share/confluent-hub-components

目前的现象:

  • 启动Kafka Connect时,日志里能看到RabbitMqConnector(source类型)成功加载;
  • 但同项目下的HttpSinkConnector(sink类型)始终没有加载记录;
  • Kafka Connect启动完成后,访问http://localhost:8083/connector-plugins端点,也只能看到RabbitMqConnector,完全找不到HttpSinkConnector的踪影。

我的项目结构如下:

src/main/java/com/example/kafkaconnector/
├── sink/
│   └── HttpSinkConnector(未加载)
└── source/
    └── RabbitMqConnector(已加载)

实在搞不懂为什么同个项目下的两个连接器,一个能正常加载另一个不行,有没有朋友能给点排查思路或者遇到过类似情况?

备注:内容来源于stack exchange,提问作者Edge

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.04.23 12:19:12