Я использую объединенный источник 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"
}
}
Вывод в теме кафки:
{"updated_on":1531323874000}
Я также пробовал from_unixtime () в запросе типа «select from_unixtime (updated_on) from temp», но это не сработало.
Есть ли способ отправить его в кафку в формате ГГГГ-ММ-ДД ЧЧ: ММ: СС?
Спасибо.