code: def __enqueue_data(self, data):
      # send a message {key:value}
      future = self.db.send(self.topic_name, **data)
      try:
          future.get(timeout=10)  # check if send successfully
      except kafka_errors:  # throw kafka_errors if failed
          traceback.format_exc()
      print("Write to Kafka successful")
  
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 4 for calling the InputQueue obj's underlying member method code with example usage: obj.__enqueue_data(data) without return types