public KafkaSubscription()

in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaSubscription.java [46:49]

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

    public KafkaSubscription(KafkaConsumer<String, byte[]> consumer, Consumer<Received> callback) {
        this.consumer = requireNonNull(consumer);
        this.callback = requireNonNull(callback);
    }