Checkout the blog post
-
Bring the dokcer compose up
docker-compose up
-
Create different topic using
Ksql
,Confluent Control Center
orKafka cli
-
make sure you update de
config.properties
file inside the project to put the right properties -
Build the project using maven
mvn clean install