public void configure()

in generic-examples/kafka/sasl_ssl/SaslSSLKafkaConsumer.java [24:29]


  public void configure() throws Exception {
    log.info("About to start route: Kafka -> Log ");
    from("kafka:{{consumer.topic}}")
        .routeId("FromKafka2Log")
        .log("${body}");
  }