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']");