public void process()

in kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/KafkaAvroMessageConsumerProcessor.java [27:30]


    public void process(Exchange exchange) throws Exception {
        String body = exchange.getIn().getBody(String.class);
        LOG.info("KafkaAvroMessageConsumerProcessor:" + body);
    }