SHARE
TWEET

Untitled

a guest Jul 19th, 2019 61 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. from kafka import KafkaConsumer
  2.  
  3. consumer = KafkaConsumer('output_event', bootstrap_servers=['abc.def.com:9092'])
  4. for msg in consumer:
  5.     print(msg.value)
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
 
Top