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 index d0c61e016889..591c1cb01058 100644 --- 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,6 @@ private void initNewWriter() { @Override public void write(SinkRecord record) { try { - // TODO: config to handle tombstones instead of always ignoring? // TODO: config to handle tombstones instead of always ignoring? if (record.value() != null) { Record row = convertToRow(record);