in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [124:126]
public synchronized void close() { closeQuietly(jsonProducer); }