diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/RecordWrapper.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/RecordWrapper.java index e4eeec45..40fb6e0a 100644 --- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/RecordWrapper.java +++ b/debezium-server-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 get(int pos, Class javaClass) { public void set(int pos, T value) { delegate.set(pos, value); } + + @Override + public String toString() { + return delegate.toString(); + } }