diff --git a/data-prepper-plugins/key-value-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/keyvalue/KeyValueProcessor.java b/data-prepper-plugins/key-value-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/keyvalue/KeyValueProcessor.java index bb4870ff31..f7329f00ad 100644 --- a/data-prepper-plugins/key-value-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/keyvalue/KeyValueProcessor.java +++ b/data-prepper-plugins/key-value-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/keyvalue/KeyValueProcessor.java @@ -177,13 +177,13 @@ public Collection> doExecute(final Collection> recor value = ((String)value).replaceAll(keyValueProcessorConfig.getDeleteValueRegex(), ""); } - if(keyValueProcessorConfig.getWhitespace().equals(WHITESPACE_STRICT)) { - String[] whitespace_arr = whitespace(key, value); + if (keyValueProcessorConfig.getWhitespace().equals(WHITESPACE_STRICT)) { + String[] whitespace_arr = trimWhitespace(key, value); key = whitespace_arr[0]; value = whitespace_arr[1]; } - if(keyValueProcessorConfig.getTransformKey() != null + if (keyValueProcessorConfig.getTransformKey() != null && !keyValueProcessorConfig.getTransformKey().isEmpty()) { key = transformKey(key); } @@ -197,7 +197,7 @@ public Collection> doExecute(final Collection> recor return records; } - private String[] whitespace(String key, Object value) { + private String[] trimWhitespace(String key, Object value) { String[] arr = {key.stripTrailing(), value.toString().stripLeading()}; return arr; }