Kafka

A look at the Camel Kafka Consumer

In this post let's look at the Kafka Camel Component. Apache Camel is an implementation of the enterprise integration patterns. The class we want is KafkaConsumer @Override protected void doStart() throws Exception { //... executor = endpoint.createExecutor(); //... for (int i = 0; i < endpoint.getConfiguration().getConsumersCount(); i++) { KafkaFetchRecords task = new KafkaFetchRecords(topic, pattern, i… Continue reading A look at the Camel Kafka Consumer