in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java [165:169]
static Iterable<Header> toHeaders(Map<String, String> properties) {
return properties.entrySet().stream()
.map(KafkaMessaging::toHeader)
.collect(Collectors.toList());
}