DBZ-7562 Add requested validate record
This commit is contained in:
parent
3fd66483d9
commit
254fc2fa1b
@ -23,6 +23,7 @@
|
|||||||
import io.debezium.connector.postgresql.PostgresConnectorConfig.SnapshotMode;
|
import io.debezium.connector.postgresql.PostgresConnectorConfig.SnapshotMode;
|
||||||
import io.debezium.connector.postgresql.connection.PostgresDefaultValueConverter;
|
import io.debezium.connector.postgresql.connection.PostgresDefaultValueConverter;
|
||||||
import io.debezium.data.Envelope;
|
import io.debezium.data.Envelope;
|
||||||
|
import io.debezium.data.VerifyRecord;
|
||||||
import io.debezium.doc.FixFor;
|
import io.debezium.doc.FixFor;
|
||||||
import io.debezium.embedded.AbstractConnectorTest;
|
import io.debezium.embedded.AbstractConnectorTest;
|
||||||
import io.debezium.junit.EqualityCheck;
|
import io.debezium.junit.EqualityCheck;
|
||||||
@ -153,6 +154,7 @@ public void shouldTruncateDefaultValuePrecisionToMatchColumnMaxPrecision() throw
|
|||||||
assertThat(recordsForTopic).hasSize(expectedRecords);
|
assertThat(recordsForTopic).hasSize(expectedRecords);
|
||||||
|
|
||||||
for (SourceRecord record : recordsForTopic) {
|
for (SourceRecord record : recordsForTopic) {
|
||||||
|
VerifyRecord.isValid(record);
|
||||||
final Struct after = ((Struct) record.value()).getStruct(Envelope.FieldName.AFTER);
|
final Struct after = ((Struct) record.value()).getStruct(Envelope.FieldName.AFTER);
|
||||||
final Schema schema = after.schema().field("cost").schema();
|
final Schema schema = after.schema().field("cost").schema();
|
||||||
assertThat(schema.parameters()).containsEntry("connect.decimal.precision", "12");
|
assertThat(schema.parameters()).containsEntry("connect.decimal.precision", "12");
|
||||||
|
Loading…
Reference in New Issue
Block a user