Skip to content

Commit 40bf95c

Browse files
committed
MYSQL Create Table doesn't pick up the schema according to debezium's binary.handling.mode
1 parent 57ff488 commit 40bf95c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

mysql-delta-plugins/src/main/java/io/cdap/delta/mysql/MySqlEventReader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ private static MySqlValueConverters getValueConverters(MySqlConnectorConfig conf
200200

201201
boolean timeAdjusterEnabled = configuration.getConfig().getBoolean(MySqlConnectorConfig.ENABLE_TIME_ADJUSTER);
202202
return new MySqlValueConverters(decimalMode, timePrecisionMode, bigIntUnsignedMode,
203-
CommonConnectorConfig.BinaryHandlingMode.BYTES,
203+
configuration.binaryHandlingMode(),
204204
timeAdjusterEnabled ? MySqlEventReader::adjustTemporal : x -> x,
205205
(message, exception) -> {
206206
throw new DebeziumException(message, exception);

0 commit comments

Comments
 (0)