public void configure()

in kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java [24:34]

• 9 lines of code
• 1 McCabe index (conditional complexity)

    public void configure() throws Exception {

        from("timer://foo?period={{period}}")
        .setBody(constant("Hi This is Avro example"))
        .process(new KafkaAvroMessageProcessor())
            .to("kafka:{{producer.topic}}?brokers={{kafka.bootstrap.url}}&keySerializer=org.apache.kafka.common.serialization.StringSerializer&valueSerializer=org.apache.camel.example.kafka.avro.CustomKafkaAvroSerializer");

        from("kafka:{{consumer.topic}}?brokers={{kafka.bootstrap.url}}&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&valueDeserializer=org.apache.camel.example.kafka.avro.CustomKafkaAvroDeserializer")
         .process(new KafkaAvroMessageConsumerProcessor())
            .log("${body}");
    }