From 632cd6716aab56d83e872db64674b5195304f1ad Mon Sep 17 00:00:00 2001 From: Bryan Keller Date: Mon, 5 Feb 2024 07:04:38 -0800 Subject: [PATCH] duplicate comment --- .../main/java/org/apache/iceberg/connect/data/IcebergWriter.java | 1 - 1 file changed, 1 deletion(-) 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);