diff --git a/src/main/java/io/debezium/connector/vitess/VitessValueConverter.java b/src/main/java/io/debezium/connector/vitess/VitessValueConverter.java index ce8bbf2b..654a5941 100644 --- a/src/main/java/io/debezium/connector/vitess/VitessValueConverter.java +++ b/src/main/java/io/debezium/connector/vitess/VitessValueConverter.java @@ -128,7 +128,7 @@ public ValueConverter converter(Column column, Field fieldDefn) { switch (column.jdbcType()) { case Types.TIME: - if (adaptiveTimeMicrosecondsPrecisionMode) { + if (temporalPrecisionMode == TemporalPrecisionMode.ADAPTIVE_TIME_MICROSECONDS) { return data -> convertDurationToMicroseconds(column, fieldDefn, data); } case Types.TIMESTAMP: