Skip to content

Latest commit

 

History

History
42 lines (27 loc) · 1.02 KB

README.md

File metadata and controls

42 lines (27 loc) · 1.02 KB

kafka-consumer

Technologies Used

  • Java
  • Spring Boot
  • Docker
  • Kubernetes
  • Kafka

Requirements

Java 11

Run Multiple Instances

Open different terminals Go to /kafka-consumer
❯ ./gradlew clean build

cd build/libs cmd :

  1. java -jar -Dserver.port=7018 -Dspring.profiles.active=production kafka-consumer-0.0.1.jar
  2. java -jar -Dserver.port=7019 -Dspring.profiles.active=production kafka-consumer-0.0.1.jar

Running it as a docker image

/kafka-consumer ❯ docker build -t kafka-load:tag .

check : docker images

Running it using Kubernetes

❯ minikube start hyperkit ❯ kubectl apply -f kafka-consumer-deployment.yaml

To track Kafka consumer group-id

/usr/local/Cellar/kafka/3.4.0/libexec/bin
❯ ./kafka-consumer-groups.sh --bootstrap-server localhost:9088 --describe --group kafka-rr-group-id