The purpose of this repo is to help me learn how to create and use a simple Kafka Consumer. Currently only supported as a single Consumer. I will look into using this in a Consumer Group in the future.
These instructions assume ~/kafka
~/kafka/bin/zookeeper-server-start.sh ~/kafka/config/zookeeper.properties
~/kafka/bin/kafka-server-start.sh ~/kafka/config/server.properties
Person_Topic will be used for this example.
~/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Person_Topic
cd kafka-consumer
mvn spring-boot:run
- Link to kafka-producer repo
cd kafka-producer
mvn spring-boot:run
- POST data locally through REST endpoint.