in rcomp-examples/kafka-appender/src/main/java/net/lr/reactive/components/appender/kafka/KafkaAppender.java [84:88]
public ProducerRecord<String,String> toRecord(Event event) {
String type = (String)event.getProperty("type");
String data = marshaller.marshal(event);
return new ProducerRecord<>(topic, type, data);
}