text: from kafka import KafkaConsumer
  from json import loads
  
  consumer = KafkaConsumer(
      'test',
      bootstrap_servers=['localhost:9092'],
      value_deserializer=lambda m: loads(m.decode('ascii')
                                       ))
  
  for message in consumer:
      print(message)
      message = message.value
      print("{ } found".format(message))
  