fix(topicdata): produce empty header key lead to a header key with ""

close #677
tchiotludo · Apr 20, 2021 · add3228 · add3228
1 parent b21bb8f
commit add3228
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/org/akhq/repositories/RecordRepository.java b/src/main/java/org/akhq/repositories/RecordRepository.java
@@ -5,6 +5,7 @@
 import com.google.common.collect.ImmutableMap;
 import io.micronaut.context.annotation.Value;
 import io.micronaut.context.env.Environment;
+import io.micronaut.core.util.StringUtils;
 import io.micronaut.http.sse.Event;
 import io.reactivex.Flowable;
 import lombok.*;
@@ -456,6 +457,7 @@ private RecordMetadata produce(
                 (headers == null ? ImmutableMap.<String, String>of() : headers)
                     .entrySet()
                     .stream()
+                    .filter(entry -> StringUtils.isNotEmpty(entry.getKey()))
                     .map(entry -> new RecordHeader(
                         entry.getKey(),
                         entry.getValue() == null ? null : entry.getValue().getBytes()