From f9e80600676ffdd719e268234972f50591bdf8ac Mon Sep 17 00:00:00 2001
From: Ismail Simsek <6005685+ismailsimsek@users.noreply.github.com>
Date: Tue, 11 Jun 2024 22:49:20 +0200
Subject: [PATCH] Fail deduplication if event key is null

---
 .../server/iceberg/tableoperator/IcebergTableOperatorTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java
index 4090cf6f..ea9b0d1c 100644
--- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java
+++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java
@@ -151,7 +151,7 @@ public void testDeduplicateBatch() throws Exception {
     Assertions.assertEquals(1, dedups2.size());
     Assertions.assertEquals("u", dedups2.get(0).value().get("__op").asText("x"));
 
-    // @TODO deduplicate wth null key
+    // deduplicating wth null key should fail!
     IcebergChangeEvent e31 = new IcebergChangeEventBuilder()
         .destination("destination")
         .addField("id", 3)