SpringCloud/stream-applications
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix more CDC tests

Browse Source
This commit is contained in:
Artem Bilan
2021-11-20 09:23:16 -05:00
parent fb5acf51f7
commit e5649c5735
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteningIntegrationTest.java
View File

@@ -110,12 +110,12 @@ public class CdcFlatteningIntegrationTest extends CdcMySqlTestSupport {
assertThat(messages).hasSize(isKafkaPresent ? 4 : 3);
assertJsonEquals(resourceToString("classpath:/json/mysql_update_inventory_customers.json"),
toString(messages.get(1).getPayload()));
toString(messages.get(1).getPayload()), Configuration.empty().whenIgnoringPaths("source.sequence"));
assertThat(messages.get(1).getHeaders().get("cdc_topic")).isEqualTo("my-app-connector.inventory.customers");
assertJsonEquals("{\"id\":" + newRecordId + "}", toString(messages.get(1).getHeaders().get("cdc_key")));
assertJsonEquals(resourceToString("classpath:/json/mysql_delete_inventory_customers.json"),
toString(messages.get(2).getPayload()));
toString(messages.get(2).getPayload()), Configuration.empty().whenIgnoringPaths("source.sequence"));
assertThat(messages.get(1).getHeaders().get("cdc_topic")).isEqualTo("my-app-connector.inventory.customers");
assertJsonEquals("{\"id\":" + newRecordId + "}", toString(messages.get(1).getHeaders().get("cdc_key")));