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

DBZ-5045 Remove deprecated FIELD_BLACKLIST

Browse Source
This commit is contained in:
Vojtech Juranek 2022-05-31 16:10:26 +02:00 committed by Jiri Pechanec
parent d66d86a3ac
commit 0d6bfec265
4 changed files with 3 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Filters.java
View File

@ -61,7 +61,7 @@ else if (collectionExcludeList != null && !collectionExcludeList.trim().isEmpty(
// Define the field selector that provides the field filter to exclude or rename fields in a document ...
fieldSelector = FieldSelector.builder()
.excludeFields(config.getFallbackStringProperty(MongoDbConnectorConfig.FIELD_EXCLUDE_LIST, MongoDbConnectorConfig.FIELD_BLACKLIST))
.excludeFields(config.getString(MongoDbConnectorConfig.FIELD_EXCLUDE_LIST))
.renameFields(config.getString(MongoDbConnectorConfig.FIELD_RENAMES))
.build();
}

14
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorConfig.java
View File

@ -410,19 +410,6 @@ public boolean isFullUpdate() {
.withValidation(MongoDbConnectorConfig::validateFieldExcludeList)
.withDescription("A comma-separated list of the fully-qualified names of fields that should be excluded from change event message values");
/**
* Old, backwards-compatible "blacklist" property.
*/
@Deprecated
public static final Field FIELD_BLACKLIST = Field.create("field.blacklist")
.withDisplayName("Deprecated: Exclude Fields")
.withType(Type.STRING)
.withWidth(Width.LONG)
.withImportance(Importance.LOW)
.withInvisibleRecommender()
.withDescription("A comma-separated list of the fully-qualified names of fields that should be excluded from change event message values (deprecated, use \""
+ FIELD_EXCLUDE_LIST.name() + "\" instead)");
/**
* A comma-separated list of the fully-qualified replacements of fields that should be used to rename fields in change
* event message values. Fully-qualified replacements for fields are of the form {@code
@ -539,7 +526,6 @@ public boolean isFullUpdate() {
DATABASE_EXCLUDE_LIST,
COLLECTION_INCLUDE_LIST,
COLLECTION_EXCLUDE_LIST,
FIELD_BLACKLIST,
FIELD_EXCLUDE_LIST,
FIELD_RENAMES,
SNAPSHOT_FILTER_QUERY_BY_COLLECTION)

4
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/Configurator.java
View File

@ -66,10 +66,6 @@ public Configurator excludeCollections(String regexList) {
}
public Configurator excludeFields(String excludeList) {
if (Math.random() >= 0.5) {
Testing.debug("Using \"" + MongoDbConnectorConfig.FIELD_BLACKLIST.name() + "\" config property");
return with(MongoDbConnectorConfig.FIELD_BLACKLIST, excludeList);
}
Testing.debug("Using \"" + MongoDbConnectorConfig.FIELD_EXCLUDE_LIST.name() + "\" config property");
return with(MongoDbConnectorConfig.FIELD_EXCLUDE_LIST, excludeList);
}

4
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/FieldBlacklistIT.java
View File

@ -1450,9 +1450,9 @@ public void shouldExcludeFieldsForDeleteTombstoneEvent() throws InterruptedExcep
assertThat(value).isNull();
}
private Configuration getConfiguration(String blackList) {
private Configuration getConfiguration(String excludeList) {
return TestHelper.getConfiguration().edit()
.with(MongoDbConnectorConfig.FIELD_BLACKLIST, blackList)
.with(MongoDbConnectorConfig.FIELD_EXCLUDE_LIST, excludeList)
.with(MongoDbConnectorConfig.COLLECTION_INCLUDE_LIST, "dbA.c1")
.with(MongoDbConnectorConfig.LOGICAL_NAME, SERVER_NAME)
.build();