如何解决mysql
尝试为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“:” xxxx“,” connection.password“:” xxxx“,” auto.create“:” true“}'
错误:{“ error_code”:405,“消息”:“ HTTP 405方法不允许”}卷曲:(3)端口号以'i'curl结尾:(3)端口号以','curl结尾: (3)端口号以't'卷曲结束:(3)端口号以'j'卷曲结束:(3)端口号以'r'卷曲结束:(3)端口号以'P'卷曲结束:(3 )端口号以't'卷曲结尾:(3)[globbing]第1列中的大括号/括号不匹配
mysql的接收器连接器不起作用,我缺少任何东西吗?
另外在连接器控制台上注意到, 错误REST调用/ connector(org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper)中未捕获的异常 javax.ws.rs.NotFoundException:找不到HTTP 404
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。