Skip to content

Commit 7303f0c

Browse files
committed
updated to debezium 2.7.4-final
1 parent d668219 commit 7303f0c

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/convert/logicaltype/DebeziumLogicalConverters.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -249,11 +249,11 @@ public Object convert(Object kafkaConnectObject) {
249249
case RECORD:
250250
return kafkaConnectObject;
251251
case FLOAT:
252-
return VariableScaleDecimal.toLogical(struct).doubleValue();
252+
return VariableScaleDecimal.toLogical(struct).toDouble();
253253
case NUMERIC:
254254
case BIGNUMERIC:
255255
default:
256-
return VariableScaleDecimal.toLogical(struct);
256+
return VariableScaleDecimal.toLogical(struct).getWrappedValue();
257257
}
258258
}
259259

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@
4545
<com.google.re2j.version>1.7</com.google.re2j.version>
4646
<com.google.auto.value.version>1.10.2</com.google.auto.value.version>
4747
<confluent.version>7.6.0</confluent.version>
48-
<debezium.version>2.3.0.Final</debezium.version>
48+
<debezium.version>2.7.4.Final</debezium.version>
4949
<jackson.version>2.14.2</jackson.version>
5050
<jetty.version>9.4.56.v20240826</jetty.version>
5151
<kafka.version>3.6.1</kafka.version>

0 commit comments

Comments
 (0)