Use RecordWrapper

memiiso · Oct 5, 2024 · fa3eea5 · fa3eea5
1 parent d581e71
commit fa3eea5
Showing 1 changed file with 4 additions and 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
@@ -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']");