From e5649c5735db4814b2a7dbde65ff66bf2ff55d10 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Sat, 20 Nov 2021 09:23:16 -0500 Subject: [PATCH] Fix more CDC tests --- .../stream/app/source/cdc/CdcFlatteningIntegrationTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteningIntegrationTest.java b/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteningIntegrationTest.java index 7d863a63..7281bdc4 100644 --- a/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteningIntegrationTest.java +++ b/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteningIntegrationTest.java @@ -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")));