Confluent Kafka Connect无法加载自定义HttpSinkConnector的问题求助
Confluent Kafka Connect无法加载自定义HttpSinkConnector的问题求助
大家好,我最近在本地部署Confluent Kafka后,遇到了自定义连接器加载异常的问题,想请教下社区的朋友们:
我是在Mac上完成Confluent Kafka安装的,现在尝试通过JAR包给本地Kafka Connect添加自定义连接器,但发现部分连接器无法正常加载。
我的操作步骤:
- 把自定义连接器模块打包成JAR文件,复制到路径
/opt/confluent-5.1.0/share/confluent-hub-components下; - 更新
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
相关产品推荐
相关产品推荐

