Merge pull request #326 from splunk/null-custom-header

handled null custom header values

Author: kashyap-splunk

.github/workflows/ci_build_test.yaml

@@ -59,6 +59,8 @@ jobs:
             kafka_package: "kafka_2.13-2.8.0.tgz"
           - kafka_version: "3.0.0"
             kafka_package: "kafka_2.13-3.0.0.tgz"
+          - kafka_version: "3.1.0"
+            kafka_package: "kafka_2.13-3.1.0.tgz"
     env:
       CI_SPLUNK_VERSION: "8.2.2"
       CI_SPLUNK_FILENAME: splunk-8.2.2-87344edfcdb4-Linux-x86_64.tgz

src/main/java/com/splunk/kafka/connect/SplunkSinkTask.java

@@ -462,7 +462,11 @@ private Event addHeaders(Event event, SinkRecord record) {
             for (String header : customHeaders) {
                     Header customHeader = headers.lastWithName(header);
                 if (customHeader != null) {
-                    headerMap.put(header, customHeader.value().toString());
+                    if (customHeader.value() == null) {
+                        headerMap.put(header, null);
+                    } else {
+                        headerMap.put(header, customHeader.value().toString());
+                    }
                 }
             }
             event.addFields(headerMap);