From 254fc2fa1be2f6ba7c9d1440298d17d8b5cd39f4 Mon Sep 17 00:00:00 2001
From: Chris Cranford <chris@hibernate.org>
Date: Tue, 27 Feb 2024 17:13:35 -0500
Subject: [PATCH] DBZ-7562 Add requested validate record

---
 .../connector/postgresql/PostgresDefaultValueConverterIT.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresDefaultValueConverterIT.java b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresDefaultValueConverterIT.java
index 563643578..a6d889a7a 100644
--- a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresDefaultValueConverterIT.java
+++ b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresDefaultValueConverterIT.java
@@ -23,6 +23,7 @@
 import io.debezium.connector.postgresql.PostgresConnectorConfig.SnapshotMode;
 import io.debezium.connector.postgresql.connection.PostgresDefaultValueConverter;
 import io.debezium.data.Envelope;
+import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
 import io.debezium.embedded.AbstractConnectorTest;
 import io.debezium.junit.EqualityCheck;
@@ -153,6 +154,7 @@ public void shouldTruncateDefaultValuePrecisionToMatchColumnMaxPrecision() throw
         assertThat(recordsForTopic).hasSize(expectedRecords);
 
         for (SourceRecord record : recordsForTopic) {
+            VerifyRecord.isValid(record);
             final Struct after = ((Struct) record.value()).getStruct(Envelope.FieldName.AFTER);
             final Schema schema = after.schema().field("cost").schema();
             assertThat(schema.parameters()).containsEntry("connect.decimal.precision", "12");