dganitch/faust-consumer repository overview

Consume 10,000 messages This process assumes a Kafka broker accessible at host.docker.internal:9092

Consumes 10,000 messages from Kafka topic named "test". Each message is a mapping representing a score. Each score has 2 keys:

index value Build the consumer docker image cd consumer

⁠-t consumer => names the image consumer, is used in kubernetes yaml file

docker build . -t consumer Apply the consumer as a Kubernetes deployment. kubectl apply -f consumer.yml Log consumer output

⁠Discover the pod running the job, e.g. consumer-32452

kubectl get pods

kubectl logs -f <pod_running_job>