如何解决Reg：Kafka 连接器配置
我正在使用 Kafka 源连接器配置将数据从源表 (Maria DB) 生成到 Kafka 主题中。对于某些表，我在连接配置中使用 mode='timestamp'。
我有两个字段 created_timestamp 和 updated_timestamp。我想根据 updated_timestamp 字段生成记录。但是，updated_timestamp 字段可能包含 NULL 值。
目前，我在查询参数中使用 NVL 函数以在 created_time 为 updated_timestamp 时选择 NULL。但是记录没有从源表飞到主题。
Kafka 源连接器配置
curl -k -X POST https://:8083/connectors -H "Content-Type: application/json" -d '{"name": "TEST_SOURCECONNECT","config": {"topic.prefix" : "topic-name","connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector","connection.url": "jdbc:MysqL://db ip","connection.user": "","connection.password": "","mode": "timestamp","query": "SELECT t.* from (SELECT *,IFNULL(updated_timestamp,created_timestamp) as custom_timestamp FROM TABLE) t","timestamp.column .name": "custom_timestamp","validate.non.null": "false","poll.interval.ms": 60000}}'
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
