private void handleRecord()

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

• 10 lines of code
• 2 McCabe index (conditional complexity)

        private void handleRecord(ConsumerRecord<String, T> record) {
            System.out.println("Handling message " + record);
            if (type == ConsumerRecord.class) {
                subscriber.onNext((T)record);
            } else {
                subscriber.onNext((T)record.value());
            }
            consumer.commitAsync();
            sent.incrementAndGet();
        }