remove unneeded TODO comments

apache · Feb 7, 2024 · 6bb988f · 6bb988f
1 parent e310514
commit 6bb988f
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/IcebergWriter.java b/kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/IcebergWriter.java
@@ -57,7 +57,7 @@ private void initNewWriter() {
   @Override
   public void write(SinkRecord record) {
     try {
-      // TODO: config to handle tombstones instead of always ignoring?
+      // ignore tombstones...
       if (record.value() != null) {
         Record row = convertToRow(record);
         String cdcField = config.tablesCdcField();
@@ -111,8 +111,6 @@ private Operation extractCdcOperation(Object recordValue, String cdcField) {
       return Operation.INSERT;
     }
 
-    // TODO: define value mapping in config?
-
     switch (opStr.charAt(0)) {
       case 'U':
         return Operation.UPDATE;