protected KafkaConsumer createConsumer()

in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [192:197]

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

    protected <T> KafkaConsumer<String, T> createConsumer(Class<? extends Deserializer<?>> deserializer, Reset reset) {
        String groupId = UUID.randomUUID().toString();
        try (CLSwitch switcher = new CLSwitch(KafkaConsumer.class.getClassLoader())) {
            return new KafkaConsumer<>(consumerConfig(deserializer, groupId, reset));
        }
    }