这个问题已经存在:
用于mysql的kafka接收器连接器[关闭]
三个月前关门了。
正在尝试为mysql创建接收器连接器,在“kafka/lib”文件夹中安装了以下.jar文件:
mysql-connector-java-8.0.21.jar kafka-connect-jdbc-5.3.1.jar插件路径=/kafka/lib
以下是curl命令:
curl-x put-h“内容类型:application/json”http://localhost:8083/connectors/quickstart mysql sink/config-d'{“name”:“quickstart mysql sink”,“connector.class”:“io.confluent.connect.jdbc.jdbcsinkconnector”,“tasks.max”:“1”,“topics”:“test”,“connection.url”:jdbc:mysql://localhost:3306/testdb“,”connection.user“:”x“,“connection.password”:“x”,“auto.create”:“true”}'
错误:{“error\u code”:405,“message”:“http 405 method not allowed”}curl:(3)端口号以“i”结尾curl:(3)端口号以“,'curl:(3)端口号以't'curl结尾:(3)端口号以'j'curl结尾:(3)端口号以'r'curl结尾:(3)端口号以'p'curl结尾:(3)端口号以't'curl结尾:(3)[globbing]列1中不匹配的右大括号/方括号
mysql的接收器连接器不工作,我遗漏了什么吗?
另外,在连接器控制台上还注意到,在对/connector(org.apache.kafka.connect.runtime.rest.errors.connectexceptionmapper)的rest调用中获取error uncaught exception javax.ws.rs.notfoundexception:http 404 not found
暂无答案!
目前还没有任何答案,快来回答吧!