public MessageSender createSender()

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);
    }