code: def consumer_demo():
      consumer = KafkaConsumer(
          "cluster-serving_serving_stream",
          bootstrap_servers=["localhost:9092"],
      )
      for message in consumer:
          print(
              "receive, key: {}, value: {}".format(
                  json.loads(message.key.decode()),
                  json.loads(message.value.decode()),
              )
          )
  
imports: from kafka import KafkaProducer, KafkaConsumer
  from kafka.errors import kafka_errors
  import traceback
  import json
  import sys
label_desc: Use image node_id 2 for calling a global function with example usage: consumer_demo() without return types