Merge pull request eventuate-foundation#150 from klausvahter/flush-lsn

eventuate-foundation#147 flush lsn when processing monitoring message
rrrship · Sep 15, 2023 · 8ba65c3 · 8ba65c3
2 parents 867b5d5 + 2e740b0
commit 8ba65c3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...nnector-postgres-wal/src/main/java/io/eventuate/local/postgres/wal/PostgresWalClient.java b/...nnector-postgres-wal/src/main/java/io/eventuate/local/postgres/wal/PostgresWalClient.java
@@ -281,6 +281,7 @@ private void checkMonitoringChange(PostgresWalMessage postgresWalMessage) {
       int index = Arrays.asList(change.getColumnnames()).indexOf("last_time");
       dbLogMetrics.onLagMeasurementEventReceived(Long.parseLong(change.getColumnvalues()[index]));
       onEventReceived();
+      offsetProcessor.saveOffset(CompletableFuture.completedFuture(Optional.of(stream.getLastReceiveLSN())));
     });
   }