private synchronized KafkaProducer kafkaProducer()

in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java [185:190]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    private synchronized KafkaProducer<String, byte[]> kafkaProducer() {
        if (producer == null) {
            producer = new KafkaProducer<>(producerConfig);
        }
        return producer;
    }