合流kafka jdbc连接查询模式

cuxqih21  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(455)

我正在使用confluent kafka connect jdbc源代码将mysql表中的记录推送到我的kafka主题,但似乎date列正在转换为epoch time。
这是我的配置:

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

Kafka主题中的输出:

  1. {"updated_on":1531323874000}

我也尝试过在查询中使用像“select from \u unixtime(updated \u on)from temp”这样的命令,但是没有用。
有没有办法用yyyy-mm-dd hh:mm:ss格式推送给Kafka?
谢谢。

yiytaume

yiytaume1#

我找不到任何办法来做这件事。
所以我更改了查询。
查询: select CAST(date_format(updated_on, \"%b %d, %Y %r\") as CHAR(50)) from temp; 这就成功了。

相关问题