我的本地机器上有confluent平台，我只是想从aws ec2示例读取数据，我有主机名、db名称、pwd等凭据，我使用的是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运行connect standalone后，出现如下错误
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
1条答案
按热度按时间b0zn9rqh1#
根据jdbcmysql语法，用户和密码在数据库地址之前用冒号分隔，而不是后面
user:password@host_or_host_sublist不确定使用rds或自己的ec2数据库是否会改变其语法如果您想捕获所有数据库事件，那么debezium（您的老问题）就是您想要的。使用jdbc连接器不会捕获删除（或在轮询之间创建和删除的事件），并且会给数据库带来不必要的压力