Error while connecting to the source db

[isyed-rl]

Hi ,

I'm getting the following error while retrieving data from postgres to snowflake using the CDC method. It used to work fine before and suddenly we are seeing errors. The error is:

Stack Trace: org.apache.kafka.connect.errors.ConnectException: Error while processing event at offset {transaction_id=null, lsn_proc=4211957836072, messageType=UPDATE, lsn_commit=4211957844032, lsn=4211957836072, txId=424022681, ts_usec=1738717717426043} at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:262) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.lambda$processMessages$0(PostgresStreamingChangeEventSource.java:279) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.decodeUpdate(PgOutputMessageDecoder.java:479) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.processNotEmptyMessage(PgOutputMessageDecoder.java:211) at io.debezium.connector.postgresql.connection.AbstractMessageDecoder.processMessage(AbstractMessageDecoder.java:41) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.deserializeMessages(PostgresReplicationConnection.java:556) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:548) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:216) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:178) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:41) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: java.lang.ClassCastException: class java.nio.HeapByteBuffer cannot be cast to class [B (java.nio.HeapByteBuffer and [B are in module java.base of loader 'bootstrap') at io.debezium.util.ApproximateStructSizeCalculator.getValueSize(ApproximateStructSizeCalculator.java:65) at io.debezium.util.ApproximateStructSizeCalculator.getStructSize(ApproximateStructSizeCalculator.java:45) at io.debezium.util.ApproximateStructSizeCalculator.getValueSize(ApproximateStructSizeCalculator.java:68) at io.debezium.util.ApproximateStructSizeCalculator.getStructSize(ApproximateStructSizeCalculator.java:45) at io.debezium.util.ApproximateStructSizeCalculator.getApproximateRecordSize(ApproximateStructSizeCalculator.java:32) at io.debezium.pipeline.DataChangeEvent.objectSize(DataChangeEvent.java:31) at io.debezium.connector.base.ChangeEventQueue.doEnqueue(ChangeEventQueue.java:223) at io.debezium.connector.base.ChangeEventQueue.enqueue(ChangeEventQueue.java:180) at io.debezium.pipeline.EventDispatcher$StreamingChangeRecordReceiver.changeRecord(EventDispatcher.java:421) at io.debezium.pipeline.EventDispatcher$2.changeRecord(EventDispatcher.java:245) at io.debezium.relational.RelationalChangeRecordEmitter.emitUpdateRecord(RelationalChangeRecordEmitter.java:124) at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:53) at io.debezium.connector.postgresql.PostgresChangeRecordEmitter.emitChangeRecords(PostgresChangeRecordEmitter.java:94) at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:225)

Please help me understand and resolve this error.

Thanks