in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [210:215]
private synchronized KafkaProducer<String, String> buildJsonKafkaProducer() {
if (jsonProducer == null) {
jsonProducer = new KafkaProducer<>(producerConfig(StringSerializer.class));
}
return jsonProducer;
}