Skip to content

Latest commit

 

History

History
41 lines (31 loc) · 953 Bytes

File metadata and controls

41 lines (31 loc) · 953 Bytes

Getting Started

These instructions will show how to run kafka locally and how to install kafkacat, a tool to display messages in a kafka topic

Run kafka locally

In a terminal cd to the root of this project and run

docker-compose up -d

Check both kafka and zookeeper are running

docker ps

Install kafkacat

Install kafkacat utility using the local package manager.

sudo apt-get install kafkacat

Start up the Producer, from the root of the project

cd sample-spring-kafka-producer
../gradlew bootRun

Start up the Consumer

cd sample-spring-kafka-consumer
../gradlew bootRun

At this point some sample messages can be generated using this endpoint:

The producer should print a message on the console that the Work unit has been dispatched and the consumer should receive and process the Work unit