mysql - 如何使用 Confluence Kafka JDBC 源连接器从亚马逊 EC2 实例中提取数据？

Question

我的本​​地计算机上有融合平台，我只是想从 aws ec2 实例读取数据，我有主机名、数据库名称、密码等凭据。我正在使用 JDBC 源连接器。连接器配置是

name=test
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector 
connection.url=jdbc:mysql://ab.bca.bdc.aaa:abcd/DB?user=abc&password=bca
table.whitelist=ppp
mode=incrementing

运行独立连接后出现错误，如

Invalid value java.sql.SQLNonTransientConnectionException: Cannot load connection class because of underlying exception: com.mysql.cj.exceptions.WrongArgumentException: Malformed database URL, failed to parse the connection string near

Answer 1

根据the JDBC MySQL syntax , 用户名和密码位于数据库地址之前(以冒号分隔)，而不是位于

之后

用户:密码@host_or_host_sublist

不确定使用 RDS 或您自己的 EC2 数据库是否会改变其语法

如果您想捕获所有数据库事件，Debezium (your old question)会是你想要的。使用 JDBC 连接器不会捕获删除(或在轮询之间创建和删除的事件)，会给数据库带来不必要的压力