Details
-
Bug
-
Resolution: Done
-
Major
-
0.7.2
-
None
Description
I have a table with a numeric array column defined as numeric_array NUMERIC(10, 2)[]
When I start the connector on this table I get the following Exception:
org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type BYTES: class org.apache.kafka.connect.data.Struct for field: "null" at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:239) at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:209) at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:253) at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:209) at org.apache.kafka.connect.data.Struct.put(Struct.java:214) at io.debezium.relational.TableSchemaBuilder.lambda$createValueGenerator$2(TableSchemaBuilder.java:198) at io.debezium.relational.TableSchema.valueFromColumnData(TableSchema.java:111) at io.debezium.connector.postgresql.RecordsSnapshotProducer.generateReadRecord(RecordsSnapshotProducer.java:295) at io.debezium.connector.postgresql.RecordsSnapshotProducer.readTable(RecordsSnapshotProducer.java:255) at io.debezium.connector.postgresql.RecordsSnapshotProducer.lambda$null$39(RecordsSnapshotProducer.java:194) at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:389) at io.debezium.connector.postgresql.RecordsSnapshotProducer.lambda$takeSnapshot$40(RecordsSnapshotProducer.java:192) at java.util.concurrent.ConcurrentHashMap$KeySpliterator.forEachRemaining(ConcurrentHashMap.java:3527) at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:580) at io.debezium.connector.postgresql.RecordsSnapshotProducer.takeSnapshot(RecordsSnapshotProducer.java:180) at io.debezium.connector.postgresql.RecordsSnapshotProducer.lambda$start$34(RecordsSnapshotProducer.java:80) at java.util.concurrent.CompletableFuture$AsyncRun.run$$$capture(CompletableFuture.java:1626) at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745)
