horrendous

databricks · Apr 9, 2024 · e190f1d · e190f1d
1 parent 3801226
commit e190f1d
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/kafka-connect/src/main/java/io/tabular/iceberg/connect/IcebergSinkTask.java b/kafka-connect/src/main/java/io/tabular/iceberg/connect/IcebergSinkTask.java
@@ -84,8 +84,12 @@ public void open(Collection<TopicPartition> partitions) {
 
   @Override
   public void put(Collection<SinkRecord> sinkRecords) {
-    writer.put(sinkRecords);
-    committer.commit(writer);
+    if (writer != null) {
+      writer.put(sinkRecords);
+      if (committer != null) {
+        committer.commit(writer);
+      }
+    }
   }
 
   @Override