Skip to content
Branch: master
Clone or download
Latest commit 5be411c Mar 6, 2018
Type Name Latest commit message Commit time
Failed to load latest commit information.
config add default kafka server config Sep 30, 2016
src clean up and add bean method reference Oct 2, 2016
.gitignore initialize repo Sep 30, 2016 Create Mar 6, 2018
LICENSE Create LICENSE Mar 6, 2018 add instructions Oct 1, 2016
pom.xml add json marsh deps Oct 1, 2016

Apache Camel Kafka Example

This application is a Spring boot example for connecting Apache Camel to Apache Kafka for Producing and Consuming messages.


To get the application going:

$ mvn clean install # Build the project
$ sudo kafka-server-start config/ # Start Kafka
$ java -jar target/ApacheCamelKafka-v0.0.1.war # Start the war

Messaging with Kafka

Run the API and hit /messages with a GET

Run the API and hit /messages with a POST body of JSON:

  "title": "Simple Notification",
  "body": "The simple notification body!"
You can’t perform that action at this time.