DBZ-5527 Fix test failures - SqlServerConnectorIT#verifyOffsets

debezium · Aug 18, 2022 · 313ded0 · 313ded0
1 parent 9b1bb0d
commit 313ded0
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...nnector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java b/...nnector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java
@@ -825,6 +825,11 @@ public void verifyOffsets() throws Exception {
         start(SqlServerConnector.class, config);
         assertConnectorIsRunning();
 
+        TestHelper.waitForStreamingStarted();
+
+        Awaitility.await().atMost(30, TimeUnit.SECONDS)
+                .until(() -> connection.getMaxLsn(TestHelper.TEST_DATABASE_1).isAvailable());
+
         final SourceRecords sourceRecords = consumeRecordsByTopic(RECORDS_PER_TABLE * TABLES);
         final List<SourceRecord> tableA = sourceRecords.recordsForTopic("server1.testDB1.dbo.tablea");
         final List<SourceRecord> tableB = sourceRecords.recordsForTopic("server1.testDB1.dbo.tableb");