Use upstream DebeziumMetrics (#111)

* Use upstream DebeziumMetrics
memiiso · Oct 1, 2022 · 9543f31 · 9543f31
1 parent 1419aae
commit 9543f31
Show file tree

Hide file tree

Showing 10 changed files with 4 additions and 101 deletions.
diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/DebeziumMetrics.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/DebeziumMetrics.java
diff --git a/...iceberg-sink/src/main/java/io/debezium/server/iceberg/batchsizewait/MaxBatchSizeWait.java b/...iceberg-sink/src/main/java/io/debezium/server/iceberg/batchsizewait/MaxBatchSizeWait.java
@@ -10,7 +10,7 @@
 
 import io.debezium.DebeziumException;
 import io.debezium.config.CommonConnectorConfig;
-import io.debezium.server.iceberg.DebeziumMetrics;
+import io.debezium.server.DebeziumMetrics;
 
 import javax.enterprise.context.Dependent;
 import javax.inject.Inject;
@@ -45,7 +45,6 @@ public class MaxBatchSizeWait implements InterfaceBatchSizeWait {
   @Override
   public void initizalize() throws DebeziumException {
     assert waitIntervalMs < maxWaitMs : "`wait-interval-ms` cannot be bigger than `max-wait-ms`";
-    dbzMetrics.initizalize();
   }
 
   @Override

diff --git a/...eberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java b/...eberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java
@@ -26,7 +26,6 @@
 import org.junit.jupiter.api.Test;
 
 /**
- * Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
  *
  * @author Ismail Simsek
  */

diff --git a/...iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java b/...iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java
@@ -26,7 +26,6 @@
 import org.junit.jupiter.api.Test;
 
 /**
- * Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
  *
  * @author Ismail Simsek
  */

diff --git a/...rver-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java b/...rver-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java
@@ -34,7 +34,7 @@
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 /**
- * Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
+ * Integration test that verifies basic reading from PostgreSQL database and writing to iceberg destination.
  *
  * @author Ismail Simsek
  */

diff --git a/...rc/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java b/...rc/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java
@@ -29,7 +29,6 @@
 import org.junit.jupiter.api.Test;
 
 /**
- * Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
  *
  * @author Ismail Simsek
  */

diff --git a/...ceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertTest.java b/...ceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertTest.java
@@ -29,7 +29,6 @@
 import org.junit.jupiter.api.Test;
 
 /**
- * Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
  *
  * @author Ismail Simsek
  */

diff --git a/...ceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergEventsChangeConsumerTest.java b/...ceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergEventsChangeConsumerTest.java
@@ -28,7 +28,6 @@
 import org.junit.jupiter.api.Test;
 
 /**
- * Integration test that verifies basic reading from PostgreSQL database and writing to s3.
  *
  * @author Ismail Simsek
  */

diff --git a/...sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java b/...sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java
@@ -32,7 +32,6 @@
 
 
 /**
- * Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
  *
  * @author Ismail Simsek
  */

diff --git a/pom.xml b/pom.xml
@@ -38,10 +38,10 @@
         <version.testcontainers>1.17.3</version.testcontainers>
         <version.kafkaclients>3.2.1</version.kafkaclients>
         <!-- Debezium -->
-        <version.debezium>1.9.5.Final</version.debezium>
+        <version.debezium>1.9.6.Final</version.debezium>
         <version.mysql.driver>8.0.28</version.mysql.driver>
         <!-- Quarkus -->
-        <version.quarkus>2.12.1.Final</version.quarkus>
+        <version.quarkus>2.12.3.Final</version.quarkus>
         <!-- ANTLR -->
         <!-- Align with Antlr runtime version pulled in via debezium -->
         <version.antlr>4.8</version.antlr>