This article covers the integration of Apache Camel with Kafka, from setup to testing, with code blocks and plenty of pictures!<\/b>
\nJoin the DZone community and get the full member experience. This article covers Apache Camel Integration with Kafka. Kafka Setup We will launch Kafka as a docker container. docker-compose.yml From the path of the docker-compose.yml file run the below command and observe that the Kafka cluster is successfully started. A screen like the below opens: Let us create 2 Springboot camel microservices, camel-demo-a and camel-demo-b camel-demo-a will publish the data to Kafka topic which will be consumed by camel-demo-b In the pom.xml of both the microservices, add the below dependency. Configure the Kafka broker URL in the application.properties Configuring the KafkaSenderRoute in camel-demo-a The route is configured to read from the file and publish to Kafka topic: Configuring the KafkaReceiverRoute in camel-demo-b Let us assume that the sender route is publishing a JSON message, which we will unmarshal and do some processing. To the pom.xml of camel-demo-b application, add below dependency: Creating the Model class: The route is configured to consume the message from the Kafka topic, unmarshal using the Jackson JSON library and do some processing. Start camel-demo-a application and place the json file in the input folder: The file will be read and the message will be published on the Kafka topic. Start camel-demo-b application. Observe that the route consumes the message from the Kafka topic, performs json unmarshalling, and further processing. Opinions expressed by DZone contributors are their own.<\/p>\n