From 1ab95314302b70c487e42c4b6f37c6d6d00de413 Mon Sep 17 00:00:00 2001 From: Don Tregonning Date: Thu, 2 May 2019 20:52:48 -0700 Subject: [PATCH] modified string split to support ',' and ', ' --- src/main/java/com/splunk/kafka/connect/SplunkSinkTask.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/splunk/kafka/connect/SplunkSinkTask.java b/src/main/java/com/splunk/kafka/connect/SplunkSinkTask.java index 65294405..71c34aa0 100644 --- a/src/main/java/com/splunk/kafka/connect/SplunkSinkTask.java +++ b/src/main/java/com/splunk/kafka/connect/SplunkSinkTask.java @@ -363,7 +363,7 @@ private Event createHecEventFrom(final SinkRecord record) { return event; } - JsonEvent event = null; + JsonEvent event; ObjectMapper objectMapper = new ObjectMapper(); if(connectorConfig.hecEventFormatted) { @@ -424,7 +424,7 @@ private Event addHeaders(Event event, SinkRecord record) { // Custom headers are configured with a comma separated list passed in configuration // "custom_header_1,custom_header_2,custom_header_3" if (!connectorConfig.headerCustom.isEmpty()) { - String[] customHeaders = connectorConfig.headerCustom.split(","); + String[] customHeaders = connectorConfig.headerCustom.split(",\\s?"); Map headerMap = new HashMap<>(); for (String header : customHeaders) { Header customHeader = headers.lastWithName(header);