from kafka import KafkaConsumer

consumer = KafkaConsumer('output_event', bootstrap_servers=['abc.def.com:9092'])
for msg in consumer:
    print(msg.value)