我已经将kafka-connect-jdbc-5.5.0.jar文件从confluent下载到我的本地计算机中。我想知道如何将这个jar添加到plugin.path=/kafka/connect。我正在尝试使用“connector.class”:“io.confluent.connect.jdbc.jdbcsinkconnector”将数据接收到mysql服务器,因此我使用的是“error\u code”:500,“message”:“找不到任何实现连接器的类以及与io.confluent.connect.jdbc.jdbcsinkconnector匹配的名称,我使用的是windows计算机中的docker工具箱
1条答案
按热度按时间pb3skfrl1#
请检查这个示例文档。它演示了如何为jdbc和elasticsearch部署sink连接器。一般来说,最重要的是要记住
plagin.path
设置为/kafka/connect
然后连接器将被分配到名为/kafka/connect/<arbitrary_name_dirname>
.