日安,
基于https://docs.confluent.io/kafka-connect-jdbc/current/index.html#installing-jdbc-drivers,我使用以下命令对jdbc连接器进行定位:
confluent-hub install confluentinc/kafka-connect-jdbc:latest命令成功运行,我可以看到confluentinc-kafka-connect-jdbc文件夹是在<confluent-plaform>/share/confluent-hub-components下创建的。
下面是显示我的安装命令结果的屏幕截图:

之后,我按照下一条指令将jdbc驱动程序jar文件上传到share/java/kafka-connect-jdbc。

之后,我使用https://docs.confluent.io/kafka-connect-jdbc/current/source-connector/index.html加载db连接器,第一步是使用list命令通过以下命令列出我拥有的连接器:
confluent local services connect connector list输出如下:
[meow@localhost confluent-7.0.1]$ confluent local services connect connector list
The local commands are intended for a single-node development environment only,
NOT for production usage. https://docs.confluent.io/current/cli/index.html
Bundled Connectors:
file-sink
file-source
replicator列表中没有连接器名jdbc-source,因此我无法继续下一步。
我能知道我的脚步犯了什么错误吗?
发布于 2022-03-11 10:10:16
在运行confluent-hub install之后,您必须重新启动Kafka工作人员,以便它获得新的连接器。
由于您使用的是合流CLI,所以命令如下:
编辑:您的屏幕截图显示,您告诉汇合集线器客户端而不是更新任何卡夫卡连接工人配置。因此,工作人员将不会拿起您安装的连接器。
您应该再次运行汇合集线器客户端,并告诉它在提示时更新Kafka工人配置,然后重新启动Kafka工作者。在那之后,它将拿起新的连接器。
https://stackoverflow.com/questions/71434887
复制相似问题