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

DBZ-4082 Logging debug info

Browse Source
This commit is contained in:
Gunnar Morling 2021-10-14 15:42:09 +02:00
parent 310a0b6ef3
commit ae1ba98591
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SchemaHistoryTopicIT.java
View File

@ -303,6 +303,13 @@ public void schemaChangeAfterSnapshot() throws Exception {
Assertions.assertThat(records.recordsForTopic("server1.dbo.tabled")).hasSize(1);
final List<SourceRecord> schemaEvents = records.recordsForTopic("server1");
// TODO DBZ-4082: schemaEvents is null occasionally when running this test on CI;
// still we got the right number of records, so I'm logging all received records here
if (schemaEvents == null) {
Testing.print("Received records: " + records.allRecordsInOrder());
}
final SourceRecord schemaEventD = schemaEvents.get(schemaEvents.size() - 1);
Assertions.assertThat(((Struct) schemaEventD.value()).getStruct("source").getString("schema")).isEqualTo("dbo");
Assertions.assertThat(((Struct) schemaEventD.value()).getStruct("source").getString("table")).isEqualTo("tabled");