Purpose

Idea is to create an application which listens to kafka and is zero downtime.
Since the app's functionality is dependent on the availability of kafka, we shall create liveliness probes for kafka and configure kubernetes to check for the health check endpoint of service, which in turn will try to connect to kafka after certain intervals, if connection couldn't be created, then the restartPolicy of the service shall be executed by k8

Tested with minikube v1.25.2

Steps to launch the application:

start zookeeper and kafka server
build image inside the minikube docker daemon - minikube image build . -t listener-app-image
launch service - kubectl apply -f deployment.yaml

Name		Name	Last commit message	Last commit date
Latest commit History 6 Commits
business_logic		business_logic
constants		constants
consumers		consumers
server		server
Dockerfile		Dockerfile
README.md		README.md
deployment.yaml		deployment.yaml
docker-compose.yml		docker-compose.yml
go.mod		go.mod
go.sum		go.sum
main.go		main.go
sample.sh		sample.sh
wait-for-it.sh		wait-for-it.sh