From fa3eea5b2adbbddf98ad6ede7c32bc89fea522dc Mon Sep 17 00:00:00 2001
From: ismail simsek <6005685+ismailsimsek@users.noreply.github.com>
Date: Sat, 5 Oct 2024 14:06:24 +0200
Subject: [PATCH] Use RecordWrapper

---
 .../java/io/debezium/server/iceberg/RecordConverter.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/RecordConverter.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/RecordConverter.java
index 0dca1d46..de816a94 100644
--- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/RecordConverter.java
+++ b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/RecordConverter.java
@@ -98,13 +98,13 @@ public Operation cdcOpValue(String cdcOpField) {
       );
     }
 
-    if (opFieldValue.equals('u')) {
+    if (opFieldValue.equals("u")) {
       return Operation.UPDATE;
-    } else if (opFieldValue.equals('d')) {
+    } else if (opFieldValue.equals("d")) {
       return Operation.DELETE;
-    } else if (opFieldValue.equals('r')) {
+    } else if (opFieldValue.equals("r")) {
       return Operation.READ;
-    } else if (opFieldValue.equals('c')) {
+    } else if (opFieldValue.equals("c")) {
       return Operation.INSERT;
     }
     throw new DebeziumException("Unexpected `" + cdcOpField + "=" + opFieldValue + "` operation value received, expecting one of ['u','d','r','c']");