我正在使用 Kafka Jdbc Connect 时间戳+递增模式将表行同步到 Kafka。引用https://docs.confluent.io/current/connect/connect-jdbc/docs/source_config_options.html#mode
面临的挑战是表格从开始时间开始同步，因为默认的开始时间是 1970 年。有什么办法可以覆盖开始时间(即，我只想从输入给定日期的开始时间同步)。
最佳答案
您需要设置timestamp.initial到输入您想要的给定日期。需要设置为纪元格式。
timestamp+incrementing中的SQL查询模式附加:
WHERE "DBTime" < 'system high date i.e. 9999-12-12T23:59:59+00:00' AND (("DBTime" = 'timestamp.initial' AND "DBKey" > '-1') OR "DBTime" > 'timestamp.initial') ORDER BY "DBTime","DBKey" ASC
关于apache-kafka - Kafka Jdbc Connect 时间戳+递增模式，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/51627472/