Check if configuration has isUnwrapped

memiiso · Jun 15, 2024 · b4234d6 · b4234d6
1 parent eea9882
commit b4234d6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeEventTest.java b/...-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeEventTest.java
@@ -11,6 +11,7 @@
 import com.fasterxml.jackson.databind.JsonNode;
 import io.debezium.serde.DebeziumSerdes;
 import io.debezium.server.iceberg.testresources.IcebergChangeEventBuilder;
+import io.quarkus.test.junit.QuarkusTest;
 import jakarta.inject.Inject;
 import org.apache.iceberg.Schema;
 import org.apache.iceberg.data.GenericRecord;
@@ -27,6 +28,7 @@
 
 import static org.junit.jupiter.api.Assertions.*;
 
+@QuarkusTest
 class IcebergChangeEventTest {
   final String serdeWithSchema = Files.readString(Path.of("src/test/resources/json/serde-with-schema.json"));
   final String unwrapWithSchema = Files.readString(Path.of("src/test/resources/json/unwrap-with-schema.json"));

diff --git a/...src/test/java/io/debezium/server/iceberg/tableoperator/IcebergChangeEventBuilderTest.java b/...src/test/java/io/debezium/server/iceberg/tableoperator/IcebergChangeEventBuilderTest.java
@@ -14,6 +14,7 @@
 import java.util.List;
 import java.util.Set;
 
+import io.quarkus.test.junit.QuarkusTest;
 import org.apache.iceberg.Schema;
 import org.apache.iceberg.types.Types;
 import org.junit.jupiter.api.Assertions;
@@ -25,6 +26,7 @@
 /**
  * @author Ismail Simsek
  */
+@QuarkusTest
 class IcebergChangeEventBuilderTest {
 
   @Test