From b4234d636f5d496d2e3e74def5e727039aed1c80 Mon Sep 17 00:00:00 2001 From: Ismail Simsek <6005685+ismailsimsek@users.noreply.github.com> Date: Sat, 15 Jun 2024 21:09:51 +0200 Subject: [PATCH] Check if configuration has isUnwrapped --- .../java/io/debezium/server/iceberg/IcebergChangeEventTest.java | 2 ++ .../iceberg/tableoperator/IcebergChangeEventBuilderTest.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeEventTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeEventTest.java index 03376a26..d8a05fda 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeEventTest.java +++ b/debezium-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/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergChangeEventBuilderTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergChangeEventBuilderTest.java index 63d326f4..09f1b86a 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergChangeEventBuilderTest.java +++ b/debezium-server-iceberg-sink/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