class_docstr: IOLayer
docstr: Obtain a KafkaIOLayer to be used with tf.keras.
  
  Args:
    topic: A `tf.string` tensor containing topic.
    partition: A `tf.int32` tensor containing partition.
    servers: A list of bootstrap servers.
    configurations: 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.
  
  Returns:
    A class of `KafkaIOLayer`.
docstr_tok: ["Obtain","a","KafkaIOLayer","to","be","used","with","tf.keras",".","Args",":","topic",":","A","`","tf.string","`","tensor","containing","topic",".","partition",":","A","`","tf.int32","`","tensor","containing","partition",".","servers",":","A","list","of","bootstrap","servers",".","configurations",":","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",".","Returns",":","A","class","of","`","KafkaIOLayer","`","."]
code: def kafka(cls, topic, partition=0, servers=None, configuration=None):
      """Obtain a KafkaIOLayer to be used with tf.keras.
  
      Args:
        topic: A `tf.string` tensor containing topic.
        partition: A `tf.int32` tensor containing partition.
        servers: A list of bootstrap servers.
        configurations: 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.
  
      Returns:
        A class of `KafkaIOLayer`.
      """
      return kafka_io_layer_ops.KafkaIOLayer(
          topic, partition, servers, configuration
      )
  
file_path: io/tensorflow_io/python/experimental/io_layer.py
imports: import tensorflow
  from tensorflow_io.python.experimental import text_io_layer_ops
  from tensorflow_io.python.experimental import kafka_io_layer_ops
label_desc: Use image node_id 4 for calling the IOLayer obj's underlying member method code with example usage: obj.kafka(cls, topic, partition, servers, configuration) and returns: kafka_io_layer_ops