class_docstr: KafkaOutputSequence
class_docstr_tok: ["KafkaOutputSequence"]
docstr: Create a `KafkaOutputSequence`.
  
  Args:
      topic: A `tf.string` tensor containing one subscription,
          in the format of topic:partition.
      servers: A list of bootstrap servers.
      configuration: A `tf.string` tensor containing global configuration
                      properties in [Key=Value] format,
                      eg. ["enable.auto.commit=false",
                          "heartbeat.interval.ms=2000"],
                      please refer to 'Global configuration properties'
                      in librdkafka doc.
docstr_tok: ["Create","a","`","KafkaOutputSequence","`",".","Args",":","topic",":","A","`","tf.string","`","tensor","containing","one","subscription",",","in","the","format","of","topic",":","partition",".","servers",":","A","list","of","bootstrap","servers",".","configuration",":","A","`","tf.string","`","tensor","containing","global","configuration","properties","in","[","Key=Value","]","format",",","eg",".","[","``","enable.auto.commit=false","''",",","``","heartbeat.interval.ms=2000","''","]",",","please","refer","to","'Global","configuration","properties'","in","librdkafka","doc","."]
code: def __init__(self, topic, servers="localhost", configuration=None):
      """Create a `KafkaOutputSequence`.
  
      Args:
          topic: A `tf.string` tensor containing one subscription,
              in the format of topic:partition.
          servers: A list of bootstrap servers.
          configuration: A `tf.string` tensor containing global configuration
                          properties in [Key=Value] format,
                          eg. ["enable.auto.commit=false",
                              "heartbeat.interval.ms=2000"],
                          please refer to 'Global configuration properties'
                          in librdkafka doc.
      """
      self._topic = topic
      metadata = list(configuration or [])
      if servers is not None:
          metadata.append("bootstrap.servers=%s" % servers)
      self._resource = core_ops.io_kafka_output_sequence(
          topic=topic, metadata=metadata
      )
  
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 to create a new KafkaOutputSequence object  with example: obj = KafkaOutputSequence(topic, servers, configuration)