我的本地计算机上有融合平台，我只是想从 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
最佳答案
根据the JDBC MySQL syntax , 用户名和密码位于数据库地址之前(以冒号分隔)，而不是位于
之后用户:密码@host_or_host_sublist
不确定使用 RDS 或您自己的 EC2 数据库是否会改变其语法
如果您想捕获所有数据库事件，Debezium (your old question)会是你想要的。使用 JDBC 连接器不会捕获删除(或在轮询之间创建和删除的事件)，会给数据库带来不必要的压力
关于mysql - 如何使用 Confluence Kafka JDBC 源连接器从亚马逊 EC2 实例中提取数据？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53117651/