From 2b22be19aff00c93b136277ace038cad7cffd490 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Tue, 30 May 2023 13:06:12 +0800
Subject: [PATCH] 'commit'

---
 src/main/java/UnitTest/OpenGaussReplicationToKafka.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/main/java/UnitTest/OpenGaussReplicationToKafka.java b/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
index ec18faf..eabcfcc 100644
--- a/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
+++ b/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
@@ -174,6 +174,9 @@ public class OpenGaussReplicationToKafka {
                 ProducerRecord<String, String> record = new ProducerRecord<>(TOPIC, res);
                 kafkaProducer.send(record);
                 System.out.println("send ok ==> " + res);
+                stream.setAppliedLSN(nowLsn);
+                stream.setFlushedLSN(nowLsn);
+                stream.forceUpdateStatus();
                 //write to redis
                 Redis.use().setex(key, EXPIRE_SECONDS, 1);
             }