Skip to content

Latest commit

 

History

History
34 lines (25 loc) · 1006 Bytes

README.md

File metadata and controls

34 lines (25 loc) · 1006 Bytes

flask-kafka-python-listener

This application is designed to listen for JSON formatted messages broadcast on Apache Kafka. It also provides an HTTP server to access the last received message.

It is designed for use with the OpenShift Python source-to-image workflow.

Quickstart on OpenShift

oc new-app centos/python-36-centos7~https://gitlab.com/bones-brigade/flask-kafka-python-listener.git \
  -e KAFKA_BROKERS=kafka:9092 \
  -e KAFKA_TOPIC=bones-brigade \
  --name=listener

You will need to adjust the KAFKA_BROKERS and KAFKA_TOPICS variables to match your configured Kafka deployment and desired topic.

After launching the application, you will want to expose a route to its service.

oc expose svc/listener

You can see the output from the HTTP server by using the following command:

curl http://`oc get routes/sparkpi --template='{{.spec.host}}'`/sparkpi?scale=5