ChainedLogicalStreamBuilder streamBuilder = pgConnection.getReplicationAPI().replicationStream().logical().withSlotName("");
PGReplicationStream stream = streamBuilder.start();
ByteBuffer byteBuffer = stream.readPending();
尝试在 TDSQL PostgreSQL 的 DN 节点中通过 wal2json 逻辑复制的方式去获取增量信息,
在 Java SDK 中重复执行几次 readPending() 方法后,报错
Caused by: com.tencentcloud.tdsql.pg.util.PSQLException: ERROR: no data left in message
at com.tencentcloud.tdsql.pg.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2678)
at com.tencentcloud.tdsql.pg.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1266)
at com.tencentcloud.tdsql.pg.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1166)
at com.tencentcloud.tdsql.pg.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:44)
at com.tencentcloud.tdsql.pg.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:161)
at com.tencentcloud.tdsql.pg.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:126)
at com.tencentcloud.tdsql.pg.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:83)