alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-7713 Fix asserts in Mysql ocp tests

Browse Source
This commit is contained in:
Jiri Novotny 2024-03-27 16:06:14 +01:00 committed by Jiří Novotný
parent e2cdc226c6
commit a8d7d20112
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-testing/debezium-testing-system/src/test/java/io/debezium/testing/system/tests/mysql/MySqlOcpTests.java
View File

@ -46,7 +46,7 @@ public void shouldStreamFromReplica(MySqlReplicaController replicaController, My
insertCustomer(masterController, "Arnold", "Test", "atest@test.com");
String topic = connectorConfig.getDbServerName() + ".inventory.customers";
awaitAssert(() -> assertions.assertRecordsCount(topic, 8));
awaitAssert(() -> assertions.assertRecordsCount(topic, 9));
awaitAssert(() -> assertions.assertRecordsContain(topic, "atest@test.com"));
}
@ -60,7 +60,7 @@ public void shouldStreamAfterMasterRestart(MySqlReplicaController replicaControl
insertCustomer(masterController, "Alex", "master", "amaster@test.com");
String topic = connectorConfig.getDbServerName() + ".inventory.customers";
awaitAssert(() -> assertions.assertRecordsCount(topic, 9));
awaitAssert(() -> assertions.assertRecordsCount(topic, 10));
awaitAssert(() -> assertions.assertRecordsContain(topic, "amaster@test.com"));
// restart only master after replication is complete, otherwise there is danger of duplicates in kafka topics
@ -76,7 +76,7 @@ public void shouldStreamAfterMasterRestart(MySqlReplicaController replicaControl
insertCustomer(masterController, "Tom", "Train", "ttrain@test.com");
awaitAssert(() -> assertions.assertRecordsCount(topic, 10));
awaitAssert(() -> assertions.assertRecordsCount(topic, 11));
awaitAssert(() -> assertions.assertRecordsContain(topic, "ttrain@test.com"));
}
}