public KafkaPoller()

in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java [64:71]

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

    public KafkaPoller(KafkaConsumer<String, String> consumer, ExceptionEventSender eventSender, List<HandlerAdapter<?>> adapters) {
        this.consumer = requireNonNull(consumer);
        this.eventSender = requireNonNull(eventSender);
        this.errorSleepMs = ERROR_SLEEP_MS;
        mapper = new ObjectMapper();
        this.handlers = adapters.stream().collect(toMap(this::typeName, this::toHandler));
        startBackgroundThread(this::run, "Message Poller");
    }