debezium-connetor-opengauss基于wal2json插件获取增量日志报错FATAL: insufficient data left in message

[zhaoshuangjian]

请问：Caused by: org.postgresql.util.PSQLException: FATAL: insufficient data left in message怎么解决呢？

详细异常信息如下：
2023-11-21 15:45:01.433 [tongcdc-vastdata_task_id-listener] ERROR c.tongtech.cdc.core.task.dbz.DebeziumChangeEventListener - [DebeziumChangeEventListener] 从 handover 中获取变更数据异常
com.tongtech.cdc.exception.CdcException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
at com.tongtech.cdc.core.task.dbz.DebeziumChangeEventListener.lambda$start$0(DebeziumChangeEventListener.java:89)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)
at io.debezium.connector.opengauss.OpengaussStreamingChangeEventSource.execute(OpengaussStreamingChangeEventSource.java:185)
at io.debezium.connector.opengauss.OpengaussStreamingChangeEventSource.execute(OpengaussStreamingChangeEventSource.java:46)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:172)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
... 3 common frames omitted
Caused by: org.postgresql.util.PSQLException: FATAL: insufficient data left in message
at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713)
at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1299)
at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1198)
at org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:44)
at org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:160)
at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:125)
at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:82)
at io.debezium.connector.opengauss.connection.OpengaussReplicationConnection$1.readPending(OpengaussReplicationConnection.java:499)
at io.debezium.connector.opengauss.OpengaussStreamingChangeEventSource.processMessages(OpengaussStreamingChangeEventSource.java:220)
at io.debezium.connector.opengauss.OpengaussStreamingChangeEventSource.execute(OpengaussStreamingChangeEventSource.java:182)
... 10 common frames omitted