in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [129:131]
public <T> MessageSender<T> createSender(String topic) {
return new KafkaJsonMessageSender<>(buildJsonKafkaProducer(), topic, eventSender);
}