public KafkaDestination()

in rcomp-kafka/src/main/java/org/apache/karaf/rcomp/kafka/KafkaDestination.java [37:43]

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

    public KafkaDestination(Properties config, String topic, Class<? extends T> type) {
        this.producer = new KafkaProducer(config);
        this.topic = topic;
        if (!((type.equals(byte[].class) || type.equals(ProducerRecord.class)))) {
            throw new IllegalArgumentException("Curently only byte[] and ProducerRecord are supported");
        }
    }