in generic-examples/kafka/sasl_ssl/SaslSSLKafkaProducer.java [25:33]
public void configure() throws Exception {
log.info("About to start route: Timer -> Kafka ");
from("timer:foo")
.routeId("FromTimer2Kafka")
.setBody()
.simple("Message #${exchangeProperty.CamelTimerCounter}")
.to("kafka:{{producer.topic}}")
.log("Message correctly sent to the topic!");
}