Package io.debezium.connector.mysql.converters

Class MysqlDebeziumTimeConverter

java.lang.Object

io.debezium.connector.mysql.converters.MysqlDebeziumTimeConverter

All Implemented Interfaces:

io.debezium.spi.converter.CustomConverter<org.apache.kafka.connect.data.SchemaBuilder,io.debezium.spi.converter.RelationalColumn>

public class MysqlDebeziumTimeConverter
extends Object
implements io.debezium.spi.converter.CustomConverter<org.apache.kafka.connect.data.SchemaBuilder,io.debezium.spi.converter.RelationalColumn>

Debezium converts the datetime type in MySQL into a UTC timestamp by default (Timestamp ), The time zone is hard-coded and cannot be changed. causing conversion errors part of the time Enable this converter to convert the four times "DATE", "DATETIME", "TIME", and "TIMESTAMP" into the format corresponding to the configured time zone (for example, yyyy-MM-dd)

See Also:

TinyIntOneToBooleanConverter

Nested Class Summary

Nested classes/interfaces inherited from interface io.debezium.spi.converter.CustomConverter

io.debezium.spi.converter.CustomConverter.Converter, io.debezium.spi.converter.CustomConverter.ConverterRegistration<S extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
protected static String	DATE_FORMAT
protected java.time.format.DateTimeFormatter	dateFormatter
protected static String	DATETIME_FORMAT
protected java.time.format.DateTimeFormatter	datetimeFormatter
protected static String	DEFAULT_DATE_FORMAT_PATTERN
protected static java.time.format.DateTimeFormatter	originalFormat
protected Boolean	parseNullDefaultValue
protected String	schemaNamePrefix
protected static String	TIME_FORMAT
protected java.time.format.DateTimeFormatter	timeFormatter
protected java.time.format.DateTimeFormatter	timestampFormatter
protected java.time.ZoneId	zoneId

Constructor Summary

Constructors

Constructor	Description
MysqlDebeziumTimeConverter()

Method Summary

Modifier and Type	Method	Description
void	configure(Properties properties)
Object	convertDateDefaultValue(io.debezium.spi.converter.RelationalColumn field)
void	converterFor(io.debezium.spi.converter.RelationalColumn field, io.debezium.spi.converter.CustomConverter.ConverterRegistration<org.apache.kafka.connect.data.SchemaBuilder> registration)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DATE_FORMAT

protected static final String DATE_FORMAT

See Also:

Constant Field Values

TIME_FORMAT

protected static final String TIME_FORMAT

See Also:

Constant Field Values

DATETIME_FORMAT

protected static final String DATETIME_FORMAT

See Also:

Constant Field Values

zoneId

protected java.time.ZoneId zoneId

DEFAULT_DATE_FORMAT_PATTERN

protected static final String DEFAULT_DATE_FORMAT_PATTERN

See Also:

Constant Field Values

dateFormatter

protected java.time.format.DateTimeFormatter dateFormatter

timeFormatter

protected java.time.format.DateTimeFormatter timeFormatter

datetimeFormatter

protected java.time.format.DateTimeFormatter datetimeFormatter

timestampFormatter

protected java.time.format.DateTimeFormatter timestampFormatter

schemaNamePrefix

protected String schemaNamePrefix

originalFormat

protected static java.time.format.DateTimeFormatter originalFormat

parseNullDefaultValue

protected Boolean parseNullDefaultValue

Constructor Detail

MysqlDebeziumTimeConverter

public MysqlDebeziumTimeConverter()

Method Detail

configure

public void configure(Properties properties)

Specified by:

configure in interface io.debezium.spi.converter.CustomConverter<org.apache.kafka.connect.data.SchemaBuilder,io.debezium.spi.converter.RelationalColumn>

converterFor

public void converterFor(io.debezium.spi.converter.RelationalColumn field,
                         io.debezium.spi.converter.CustomConverter.ConverterRegistration<org.apache.kafka.connect.data.SchemaBuilder> registration)

Specified by:

converterFor in interface io.debezium.spi.converter.CustomConverter<org.apache.kafka.connect.data.SchemaBuilder,io.debezium.spi.converter.RelationalColumn>

convertDateDefaultValue

public Object convertDateDefaultValue(io.debezium.spi.converter.RelationalColumn field)