a guest Jul 19th, 2019 61 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
- from kafka import KafkaConsumer
- consumer = KafkaConsumer('output_event', bootstrap_servers=['abc.def.com:9092'])
- for msg in consumer:
RAW Paste Data