From 7db45515533aabef4f1d3eeb0c9cacbbc00f8d04 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 11:45:40 +0800
Subject: [PATCH] 'commit'

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

diff --git a/src/main/java/UnitTest/OpenGaussReplicationToKafka.java b/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
index b8b4a25..d1c72c9 100644
--- a/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
+++ b/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
@@ -69,6 +69,13 @@ public class OpenGaussReplicationToKafka {
         return null;
     }
 
+    public static String GetRestartLsn(String slotName) {
+        String sql = "select restart_lsn from pg_replication_slots where slot_name=?";
+        List<Record> list = Db.find(sql, slotName);
+        if (list.size() > 0) return list.get(0).getStr("restart_lsn");
+        return null;
+    }
+
     public static void InsertTestData() {
         String sql = "select max(id) as maxid from test";
         int maxId = 0;
@@ -157,6 +164,8 @@ public class OpenGaussReplicationToKafka {
                 stream.setAppliedLSN(stream.getLastReceiveLSN());
                 stream.setFlushedLSN(stream.getLastReceiveLSN());
                 stream.forceUpdateStatus();
+
+                System.out.println(stream.getLastReceiveLSN());
             }
         } catch (Exception err) {
             if (stream != null) {