Skip to content
Branch: master
Find file History
Type Name Latest commit message Commit time
Failed to load latest commit information.
src config: update broker address Oct 4, 2019 scs-kafka-demo: adding readme Oct 2, 2019
pom.xml scs-kafka-demo: demo project explaining spring cloud stream and kafka Oct 2, 2019

Kafka with Spring Cloud Stream

A sample project to demonstrate how to connect to Kafka using Spring Cloud Stream framework.


This project uses maven for build purpose. Run below command to run the build.

mvn clean install

Running the application

mvn spring-boot:run


The application has two REST Apis which internall call the producer. Below are the sample curl commands to make the http call.

curl -X POST \
  http://localhost:8080/sendMessage/string \
  -H 'Content-Type: application/json' \
  -d hello

curl -X POST \
  http://localhost:8080/sendMessage/complexType \
  -H 'Content-Type: application/json' \
  -d '{
    "contents": "hello"

You should be able to see the consumer logs in the console.

You can’t perform that action at this time.