Confluent kafka jdbc 连接查询方式
Confluent kafka jdbc connect query mode
我正在使用 confluent kafka connect jdbc 源将记录从 mysql table 推送到我的 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?
谢谢。
我找不到任何方法。
所以我更改了查询。
查询:select CAST(date_format(updated_on, \"%b %d, %Y %r\") as CHAR(50)) from temp;
这成功了。
我正在使用 confluent kafka connect jdbc 源将记录从 mysql table 推送到我的 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?
谢谢。
我找不到任何方法。
所以我更改了查询。
查询:select CAST(date_format(updated_on, \"%b %d, %Y %r\") as CHAR(50)) from temp;
这成功了。