小编scr*_*die的帖子

Kafka 连接可以使用批量模式的自定义查询吗?

我正在尝试发送 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)

apache-kafka apache-kafka-connect

2
推荐指数
1
解决办法
3585
查看次数

标签 统计

apache-kafka ×1

apache-kafka-connect ×1