Module Import alias ImportFrom alias If CompareEq NameLoad Str body Assign NameStore Call AttributeLoad NameLoad attr keyword Str Expr Call AttributeLoad NameLoad attr Str keyword Str Expr Call AttributeLoad NameLoad attr Str keyword Str Expr Call AttributeLoad NameLoad attr Str Str keyword Str keyword Str Assign NameStore Call AttributeLoad NameLoad attr Print Call AttributeLoad Str attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call NameLoad AttributeLoad NameLoad attr keyword ListLoad Call AttributeLoad Str attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword Str For NameStore NameLoad body Print Call AttributeLoad Str attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str
N/A N/A argparse kafka KafkaConsumer N/A N/A __name__ __main__ N/A N/A parser N/A N/A argparse ArgumentParser description Consume messages from kafka. N/A N/A N/A parser add_argument host help A Kafka host N/A N/A N/A parser add_argument topic help A topic to consume N/A N/A N/A parser add_argument -p --port default 9092 help A Kafka port, default 9092. N/A args N/A N/A parser parse_args N/A N/A N/A Trying to get messages from topic {0} on {1}:{2} format N/A args topic N/A args host N/A args port N/A consumer N/A KafkaConsumer N/A args topic bootstrap_servers N/A N/A N/A {0}:{1} format N/A args host N/A args port auto_offset_reset smallest N/A message consumer N/A N/A N/A N/A {0}:{1}:{2}: key={3} value={4} format N/A message topic N/A message partition N/A message offset N/A message key N/A N/A N/A message value decode utf-8