public void process()

in kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/KafkaAvroProcessor.java [32:39]

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

    public void process(Exchange exc) throws Exception {
        @SuppressWarnings("unchecked")
        List<RecordMetadata> recordMetaData1 = (List<RecordMetadata>) exc.getIn().getHeader(KafkaConstants.KAFKA_RECORDMETA);
        for (RecordMetadata rd: recordMetaData1) {
            LOG.info("producer partition is:"  + rd.partition());
            LOG.info("producer partition message is:"  + rd.toString());
        }
    }