融合kafka jdbc连接查询模式

Question

我正在使用合流kafka connect jdbc源将mysql表中的记录推送到我的kafka主题，但似乎日期列被转换为纪元时间。

这是我的配置：

{
    "name": "mysql-source-test", 
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
            "tasks.max": "5",
            "name": "mysql-source-test",
            "connection.url":"jdbc:mysql://localhost:3306/brint?user=abc&password=xyz",
            "topic.prefix":"mysql-source-test",
            "poll.interval.ms":"100000000",
            "query":"select updated_on from temp;",
            "mode":"timestamp",
            "batch.max.rows":"10"
    }
}

kafka主题中的输出：

{"updated_on":1531323874000}

我也在类似于“select from_unixtime(updated _ on)from temp”的查询中尝试了from _ unixtime()，但是那不行。

有没有办法推到YYYY-MM-DD HH:MM:SS格式的Kafka？

谢谢你。

Answer 1

我找不到做这件事的任何方法。

所以我更改了查询。

查询：从temp中选择CAST（date_format（updated_on，\"%b%d，%Y%r\"）作为CHAR（50））；

这奏效了。