我正在尝试发送 7 天前的每行记录。这是我正在处理的配置,但即使查询在数据库服务器上生成记录,它也不起作用。
{
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": 1,
"mode": "bulk",
"connection.url": "jdbc:mysql://mysql:3300/test_db?user=root&password=password",
"query": "SELECT * FROM test_table WHERE DATEDIFF(CURDATE(), test_table.modified) = 7;",
"topic.prefix": "test-jdbc-",
"poll.interval.ms": 10000
}Run Code Online (Sandbox Code Playgroud)