in kafka/src/main/java/org/apache/camel/example/kafka/MessageConsumerClient.java [55:67]
static RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("kafka:{{consumer.topic}}"
+ "?maxPollRecords={{consumer.maxPollRecords}}"
+ "&consumersCount={{consumer.consumersCount}}"
+ "&seekTo={{consumer.seekTo}}"
+ "&groupId={{consumer.group}}")
.routeId("FromKafka")
.log("${body}");
}
};
}