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

DBZ-7698 fix some failing tests

Browse Source
This commit is contained in:
twthorn 2024-03-29 10:49:03 -05:00 committed by Jiri Pechanec
parent ea8dddade3
commit 24e4e4eb80
3 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/MongoDbConnectorTest.java
View File

@ -38,7 +38,7 @@ protected static void assertConfigDefIsValid(Connector connector, io.debezium.co
assertThat(key.importance).isEqualTo(expected.importance());
assertThat(key.documentation).isEqualTo(expected.description());
assertThat(key.type).isEqualTo(expected.type());
if (expected.type() == Type.CLASS) {
if (expected.type() == Type.CLASS && expected.defaultValue() != null) {
assertThat(((Class<?>) key.defaultValue).getName()).isEqualTo((String) expected.defaultValue());
}
else if (expected.type() == ConfigDef.Type.LIST && key.defaultValue != null) {

10
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresConnectorConfig.java
View File

@ -33,7 +33,9 @@
import io.debezium.connector.postgresql.connection.ReplicationConnection;
import io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder;
import io.debezium.connector.postgresql.connection.pgproto.PgProtoMessageDecoder;
import io.debezium.connector.postgresql.pipeline.txmetadata.PostgresTransactionStructMaker;
import io.debezium.jdbc.JdbcConfiguration;
import io.debezium.pipeline.txmetadata.TransactionStructMaker;
import io.debezium.relational.ColumnFilterMode;
import io.debezium.relational.RelationalDatabaseConnectorConfig;
import io.debezium.relational.TableId;
@ -962,6 +964,9 @@ public static AutoCreateMode parse(String value, String defaultValue) {
public static final Field SOURCE_INFO_STRUCT_MAKER = CommonConnectorConfig.SOURCE_INFO_STRUCT_MAKER
.withDefault(PostgresSourceInfoStructMaker.class.getName());
public static final Field TRANSACTION_STRUCT_MAKER = CommonConnectorConfig.TRANSACTION_STRUCT_MAKER
.withDefault(PostgresTransactionStructMaker.class.getName());
private final LogicalDecodingMessageFilter logicalDecodingMessageFilter;
private final HStoreHandlingMode hStoreHandlingMode;
private final IntervalHandlingMode intervalHandlingMode;
@ -1114,6 +1119,11 @@ protected SourceInfoStructMaker<? extends AbstractSourceInfo> getSourceInfoStruc
return getSourceInfoStructMaker(SOURCE_INFO_STRUCT_MAKER, Module.name(), Module.version(), this);
}
@Override
public TransactionStructMaker getTransactionStructMaker() {
return getTransactionStructMaker(TRANSACTION_STRUCT_MAKER);
}
private static final ConfigDefinition CONFIG_DEFINITION = RelationalDatabaseConnectorConfig.CONFIG_DEFINITION.edit()
.name("Postgres")
.excluding(CommonConnectorConfig.SKIPPED_OPERATIONS)

5
debezium-core/src/main/java/io/debezium/config/CommonConnectorConfig.java
View File

@ -722,9 +722,10 @@ public static SnapshotQueryMode parse(String value, String defaultValue) {
public static final Field PROVIDE_ORDERED_TRANSACTION_METADATA = Field.create("provide.ordered.transaction.metadata")
.withDisplayName("Provide ordered transaction meatadata")
.withType(Type.BOOLEAN)
.withDefault(false)
.withGroup(Field.createGroupEntry(Field.Group.CONNECTOR_ADVANCED, 19))
.withWidth(Width.SHORT)
.withImportance(ConfigDef.Importance.LOW)
.withDefault(Boolean.FALSE)
.withImportance(Importance.LOW)
.withDescription(
"Whether to provide order metadata on transactions");