public void configure()

in generic-examples/kafka/SampleKafkaConsumer.java [22:31]

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

  public void configure() throws Exception {
    log.info("About to start route: Kafka Server -> Log ");
    from("kafka:{{consumer.topic}}?brokers={{kafka.host}}:{{kafka.port}}"
        + "&maxPollRecords={{consumer.maxPollRecords}}"
        + "&consumersCount={{consumer.consumersCount}}"
        + "&seekTo={{consumer.seekTo}}"
        + "&groupId={{consumer.group}}")
        .routeId("FromKafka")
        .log("${body}");
  }