public void activate()

in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java [96:107]

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

    public void activate(KafkaEndpoint endPoint) {
        this.endPoint = endPoint;
        producerConfig = new HashMap<>();
        producerConfig.put(KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        producerConfig.put(VALUE_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
        producerConfig.put(BOOTSTRAP_SERVERS_CONFIG, endPoint.kafkaBootstrapServers());
        // We favour durability over throughput
        // and thus requires full acknowledgment
        // from replica leader and followers.
        producerConfig.put(ACKS_CONFIG, "all");
        producerConfig = unmodifiableMap(producerConfig);
    }