diff --git a/kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordProjection.java b/kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordProjection.java index 79ce2c111a3a..41972f2ccede 100644 --- a/kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordProjection.java +++ b/kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordProjection.java @@ -164,7 +164,7 @@ public T get(int pos, Class javaClass) { @Override public void set(int pos, T value) { - throw new UnsupportedOperationException(); + throw new UnsupportedOperationException("RecordProjection.set(int, Object) is not supported"); } @Override @@ -174,12 +174,13 @@ public StructType struct() { @Override public Object getField(String name) { - throw new UnsupportedOperationException(); + throw new UnsupportedOperationException("RecordProjection.getField(String) is not supported"); } @Override public void setField(String name, Object value) { - throw new UnsupportedOperationException(); + throw new UnsupportedOperationException( + "RecordProjection.setField(String, Object) is not supported"); } @Override @@ -189,11 +190,11 @@ public Object get(int pos) { @Override public Record copy() { - throw new UnsupportedOperationException(); + throw new UnsupportedOperationException("RecordProjection.copy() is not supported"); } @Override public Record copy(Map overwriteValues) { - throw new UnsupportedOperationException(); + throw new UnsupportedOperationException("RecordProjection.copy(Map) is not supported"); } }