diff --git a/webservice/listen_kafka.py b/webservice/listen_kafka.py new file mode 100644 index 0000000000000000000000000000000000000000..2c5e155abbaaec41a663a24154ac911e25bba1e1 --- /dev/null +++ b/webservice/listen_kafka.py @@ -0,0 +1,24 @@ +"""Print Kafka events sent by the webservice. +""" +import json +import os.path as osp + +import yaml +from kafka import KafkaConsumer + +conf_file = osp.join(osp.dirname(__file__), 'webservice.yaml') + +with open(conf_file, "r") as f: + config = yaml.safe_load(f) + +topic = config['kafka']['topic'] +brokers = config['kafka']['brokers'] +print(f"topic: {topic!r}") +print(f"brokers: {brokers!r}") + +kc = KafkaConsumer(topic, bootstrap_servers=brokers) + +print("Waiting for messages (Ctrl-C to quit)...") +for record in kc: + msg = json.loads(record.value.decode()) + print(msg)