code: def write_kafka(message, topic, servers="localhost", name=None):
      """Write messages to the kafka topic
  
      Args:
          message: The `tf.string` tensor containing the message
              to be written into the topic.
          topic: A `tf.string` tensor containing one subscription,
              in the format of topic:partition.
          servers: A list of bootstrap servers.
          name: A name for the operation (optional).
      Returns:
          A `Tensor` of type `string`. 0-D.
      """
      return core_ops.io_write_kafka(
          message=message, topic=topic, servers=servers, name=name
      )
  
file_path: io/tensorflow_io/python/ops/kafka_deprecated_dataset_ops.py
imports: import warnings
  import tensorflow
  from tensorflow import dtypes
  from tensorflow.compat.v1 import data
  from tensorflow_io.python.ops import core_ops
  from tensorflow_io.python.utils import deprecation
label_desc: Use image node_id 1 for calling a global function with example usage: write_kafka(message, topic, servers, name) and returns: core_ops