Skip to content

Commit 28190c8

Browse files
fix #620 : support sending null headers in POST send message request
1 parent c8a8759 commit 28190c8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

api/src/main/java/io/kafbat/ui/serdes/ProducerRecordCreator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public ProducerRecord<byte[], byte[]> create(String topic,
3131

3232
private Iterable<Header> createHeaders(Map<String, String> clientHeaders) {
3333
RecordHeaders headers = new RecordHeaders();
34-
clientHeaders.forEach((k, v) -> headers.add(new RecordHeader(k, v.getBytes())));
34+
clientHeaders.forEach((k, v) -> headers.add(new RecordHeader(k, v == null ? null : v.getBytes())));
3535
return headers;
3636
}
3737

0 commit comments

Comments
 (0)