Skip to content

Commit f5fb854

Browse files
set null for null headers, instead of ignoring them
1 parent 8b2a687 commit f5fb854

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -461,8 +461,12 @@ private Event addHeaders(Event event, SinkRecord record) {
461461
Map<String, String> headerMap = new HashMap<>();
462462
for (String header : customHeaders) {
463463
Header customHeader = headers.lastWithName(header);
464-
if (customHeader != null && customHeader.value() != null) {
465-
headerMap.put(header, customHeader.value().toString());
464+
if (customHeader != null) {
465+
if (customHeader.value() == null) {
466+
headerMap.put(header, null);
467+
} else {
468+
headerMap.put(header, customHeader.value().toString());
469+
}
466470
}
467471
}
468472
event.addFields(headerMap);

0 commit comments

Comments
 (0)