private KafkaConsumer buildKafkaConsumer()

in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java [192:205]

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

    private KafkaConsumer<String, byte[]> buildKafkaConsumer(Seek seek) {

        String groupId = UUID.randomUUID().toString();

        Map<String, Object> consumerConfig = new HashMap<>();
        consumerConfig.put(BOOTSTRAP_SERVERS_CONFIG, endPoint.kafkaBootstrapServers());
        consumerConfig.put(GROUP_ID_CONFIG, groupId);
        consumerConfig.put(ENABLE_AUTO_COMMIT_CONFIG, false);
        consumerConfig.put(KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        consumerConfig.put(VALUE_DESERIALIZER_CLASS_CONFIG, ByteArrayDeserializer.class);
        consumerConfig.put(AUTO_OFFSET_RESET_CONFIG, seek.name());

        return new KafkaConsumer<>(unmodifiableMap(consumerConfig));
    }