From d668219f87e3acc4a3872a400f11c5b47dc5feee Mon Sep 17 00:00:00 2001
From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com>
Date: Fri, 12 Sep 2025 14:36:31 +0000
Subject: [PATCH 1/2] Bump io.debezium:debezium-core from 0.6.2 to 2.3.0.Final

Bumps io.debezium:debezium-core from 0.6.2 to 2.3.0.Final.

---
updated-dependencies:
- dependency-name: io.debezium:debezium-core
  dependency-version: 2.3.0.Final
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
---
 pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index e28fa6e6..b027e08d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -45,7 +45,7 @@
         <com.google.re2j.version>1.7</com.google.re2j.version>
         <com.google.auto.value.version>1.10.2</com.google.auto.value.version>
         <confluent.version>7.6.0</confluent.version>
-        <debezium.version>0.6.2</debezium.version>
+        <debezium.version>2.3.0.Final</debezium.version>
         <jackson.version>2.14.2</jackson.version>
         <jetty.version>9.4.56.v20240826</jetty.version>
         <kafka.version>3.6.1</kafka.version>

From 7303f0c49f57a51d3b2a4cbfa10643ede70b0563 Mon Sep 17 00:00:00 2001
From: Claude Warren <claude.warren@aiven.io>
Date: Mon, 20 Oct 2025 13:07:50 +0100
Subject: [PATCH 2/2] updated to debezium 2.7.4-final

---
 .../convert/logicaltype/DebeziumLogicalConverters.java        | 4 ++--
 pom.xml                                                       | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/convert/logicaltype/DebeziumLogicalConverters.java b/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/convert/logicaltype/DebeziumLogicalConverters.java
index a2fe5552..b3d74831 100644
--- a/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/convert/logicaltype/DebeziumLogicalConverters.java
+++ b/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/convert/logicaltype/DebeziumLogicalConverters.java
@@ -249,11 +249,11 @@ public Object convert(Object kafkaConnectObject) {
         case RECORD:
           return kafkaConnectObject;
         case FLOAT:
-          return VariableScaleDecimal.toLogical(struct).doubleValue();
+          return VariableScaleDecimal.toLogical(struct).toDouble();
         case NUMERIC:
         case BIGNUMERIC:
         default:
-          return VariableScaleDecimal.toLogical(struct);
+          return VariableScaleDecimal.toLogical(struct).getWrappedValue();
       }
     }
 
diff --git a/pom.xml b/pom.xml
index b027e08d..970f18aa 100644
--- a/pom.xml
+++ b/pom.xml
@@ -45,7 +45,7 @@
         <com.google.re2j.version>1.7</com.google.re2j.version>
         <com.google.auto.value.version>1.10.2</com.google.auto.value.version>
         <confluent.version>7.6.0</confluent.version>
-        <debezium.version>2.3.0.Final</debezium.version>
+        <debezium.version>2.7.4.Final</debezium.version>
         <jackson.version>2.14.2</jackson.version>
         <jetty.version>9.4.56.v20240826</jetty.version>
         <kafka.version>3.6.1</kafka.version>