2b374fa8ae
* upgrade to spring boot 1.5.2 * add full update to REST API * modify ratings controller * upgrade herold * fix integration test * fix integration test * minor fix * fix integration test * fix integration test * minor cleanup * minor cleanup * remove log4j properties * use standard logbook.xml * remove log4j dependencies * remove commons-logging * merge * fix conflict * exclude commons-logging dependency * cleanup * minor fix * minor fix * fix dependency issues * Revert "fix dependency issues" This reverts commit 83bf1f9fd2e1a9a55f9cacb085669568b06b49ec. * fix dependency issues * minor fix * minor fix * minor fix * cleanup generated files * fix commons-logging issue * add parent to pom * cleanup parent dependencies * cleanup pom * cleanup pom |
||
|---|---|---|
| .. | ||
| src/main | ||
| README.md | ||
| pom.xml | ||
README.md
Relevant articles
Spring Kafka
This is a simple Spring Boot app to demonstrate sending and receiving of messages in Kafka using spring-kafka.
As Kafka topics are not created automatically by default, this application requires that you create the following topics manually.
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic baeldung
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 5 --topic partitioned
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic filtered
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic greeting
When the application runs successfully, following output is logged on to console (along with spring logs):
Message received from the 'baeldung' topic by the basic listeners with groups foo and bar
Received Message in group 'foo': Hello, World!
Received Message in group 'bar': Hello, World!
Message received from the 'baeldung' topic, with the partition info
Received Message: Hello, World! from partition: 0
Message received from the 'partitioned' topic, only from specific partitions
Received Message: Hello To Partioned Topic! from partition: 0
Received Message: Hello To Partioned Topic! from partition: 3
Message received from the 'filtered' topic after filtering
Received Message in filtered listener: Hello Baeldung!
Message (Serialized Java Object) received from the 'greeting' topic
Received greeting message: Greetings, World!!