Use RecordWrapper

memiiso · Oct 5, 2024 · 8fc3705 · 8fc3705
1 parent fa3eea5
commit 8fc3705
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...er-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/RecordWrapper.java b/...er-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/RecordWrapper.java
@@ -18,7 +18,6 @@
  */
 package io.debezium.server.iceberg.tableoperator;
 
-import org.apache.iceberg.data.GenericRecord;
 import org.apache.iceberg.data.Record;
 import org.apache.iceberg.types.Types.StructType;
 
@@ -82,4 +81,9 @@ public <T> T get(int pos, Class<T> javaClass) {
   public <T> void set(int pos, T value) {
     delegate.set(pos, value);
   }
+
+  @Override
+  public String toString() {
+    return delegate.toString();
+  }
 }