Skip to content
This repository was archived by the owner on Mar 2, 2023. It is now read-only.

README.md

Latest commit

 

History

History
36 lines (26 loc) · 2.47 KB

README.md

File metadata and controls

36 lines (26 loc) · 2.47 KB
Raw

Note: debezium has been upgraded and the repository is no longer maintained. Please see the latest official documentation

Debezium architecture

Build Status(https://github.com/holmofy/debezium-datetime-converter/actions/workflows/release.yml/badge.svg)

debezium-datetime-converter

Debezium custom converter is used to deal with mysql datetime type problems.

mysql binlog-connector debezium schema
date
(2021-01-28)		 LocalDate
(2021-01-28)		 Integer
(18655)		 io.debezium.time.Date
time
(17:29:04)		 Duration
(PT17H29M4S)		 Long
(62944000000)		 io.debezium.time.Time
timestamp
(2021-01-28 17:29:04)		 ZonedDateTime
(2021-01-28T09:29:04Z)		 String
(2021-01-28T09:29:04Z)		 io.debezium.time.ZonedTimestamp
Datetime
(2021-01-28 17:29:04)		 LocalDateTime
(2021-01-28T17:29:04)		 Long
(1611854944000)		 io.debezium.time.Timestamp

For details, please refer to this article

Usage

  1. Download the extended jar package and put it in the same level directory of the debezium plugin.

  2. In debezium-connector, Add the following configuration:

connector.class=io.debezium.connector.mysql.MySqlConnector
# ...
converters=datetime
datetime.type=com.darcytech.debezium.converter.MySqlDateTimeConverter
datetime.format.date=yyyy-MM-dd
datetime.format.time=HH:mm:ss
datetime.format.datetime=yyyy-MM-dd HH:mm:ss
datetime.format.timestamp=yyyy-MM-dd HH:mm:ss
datetime.format.timestamp.zone=UTC+8