code: def dequeue(self):
      # poll get records
      records = self.db.poll(timeout_ms=500)
      self.db.commit()
      decoded = {}
      for tp, messages in records.items():
          for message in messages:
              res_id = message.key.decode()
              res_value = message.value.decode()
              decoded[res_id] = self.get_ndarray_from_b64(
                  res_value
              )  # decode value
      return decoded
  
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 2 for calling the OutputQueue obj's underlying member method code with example usage: obj.dequeue() and returns: decoded