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

DBZ-7142 Improved Outbox Event Router SMT to handle whitespaces inside of fields.additional.placement setting

Browse Source
This commit is contained in:
ruslan 2023-11-15 20:52:03 +04:00 committed by Jiri Pechanec
parent f429536a75
commit daf7f57d77
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-core/src/main/java/io/debezium/transforms/outbox/EventRouterConfigDefinition.java
View File

@ -328,9 +328,9 @@ static List<AdditionalField> parseAdditionalFieldsConfig(Configuration config) {
if (extraFieldsMapping != null) { if (extraFieldsMapping != null) {
for (String field : extraFieldsMapping.split(",")) { for (String field : extraFieldsMapping.split(",")) {
final String[] parts = field.split(":"); final String[] parts = field.split(":");
final String fieldName = parts[0]; final String fieldName = parts[0].trim();
AdditionalFieldPlacement placement = AdditionalFieldPlacement.parse(parts[1]); AdditionalFieldPlacement placement = AdditionalFieldPlacement.parse(parts[1].trim());
final AdditionalField addField = new AdditionalField(placement, fieldName, parts.length == 3 ? parts[2] : fieldName); final AdditionalField addField = new AdditionalField(placement, fieldName, parts.length == 3 ? parts[2].trim() : fieldName);
additionalFields.add(addField); additionalFields.add(addField);
} }
} }

2
debezium-core/src/test/java/io/debezium/transforms/outbox/EventRouterTest.java
View File

@ -651,7 +651,7 @@ public void canSetMultipleFieldsIntoTheEnvelope() {
final Map<String, String> config = new HashMap<>(); final Map<String, String> config = new HashMap<>();
config.put( config.put(
EventRouterConfigDefinition.FIELDS_ADDITIONAL_PLACEMENT.name(), EventRouterConfigDefinition.FIELDS_ADDITIONAL_PLACEMENT.name(),
"type:envelope:payloadType,aggregateid:envelope:payloadId,type:header:payloadType"); "type:envelope:payloadType, aggregateid:envelope:payloadId,type:header:payloadType");
router.configure(config); router.configure(config);
final SourceRecord eventRecord = createEventRecord(); final SourceRecord eventRecord = createEventRecord();