3 years ago

Category: Data, Docker, yaml

From the path of the docker-compose.yml file run the below command and observe that the Kafka cluster is successfully started.

The route is configured to read from the file and publish to Kafka topic: Configuring the KafkaReceiverRoute in camel-demo-b

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.