public KafkaSource()

in rcomp-kafka/src/main/java/org/apache/karaf/rcomp/kafka/KafkaSource.java [39:46]

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

    public KafkaSource(Properties config, String topic, Class<? extends T> type) {
        this.consumer = new KafkaConsumer(config);
        this.topic = topic;
        if (!(type == String.class || type == ConsumerRecord.class)) {
            throw new IllegalArgumentException("Curently only String and ProducerRecord are supported");
        }
        this.type = type;
    }