code: def __init__(
      self,
      host=None,
      port=None,
      group_id="group-1",
      auto_offset_reset="earliest",
      **kwargs,
  ):
      host = host if host else "localhost"
      port = port if port else "9092"
      self.topic_name = (
          kwargs.get("topic_name")
          if kwargs.get("topic_name")
          else RESULT_PREFIX + "serving_stream"
      )
  
      for key in ["host", "port", "topic_name"]:
          if key in kwargs:
              kwargs.pop(key)
      # create a kafka consumer
      self.db = KafkaConsumer(
          self.topic_name,
          bootstrap_servers=host + ":" + port,
          group_id=group_id,
          auto_offset_reset=auto_offset_reset,
          **kwargs,
      )
  
file_path: BigDL/python/serving/src/bigdl/serving/kafka/client.py
imports: from kafka import KafkaProducer, KafkaConsumer
  from kafka.errors import kafka_errors
  import json
  from bigdl.serving.schema import *
  from bigdl.serving.log4Error import invalidInputError
label_desc: Use image node_id 1 to create a new OutputQueue object  with example: obj = OutputQueue(host, port, group_id, auto_offset_reset)