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)