class_docstr: KafkaIOTensor
code: def __init__(
      self, topic, partition, servers, configuration, internal=True
  ):
      with tf.name_scope("KafkaIOTensor"):
          assert internal
  
          metadata = list(configuration or [])
          if servers is not None:
              metadata.append("bootstrap.servers=%s" % servers)
          resource = core_ops.io_kafka_readable_init(
              topic, partition, offset=0, metadata=metadata
          )
  
          self._resource = resource
          super().__init__()
  
file_path: io/tensorflow_io/python/ops/kafka_io_tensor_ops.py
imports: import tensorflow
  from tensorflow_io.python.ops import core_ops
label_desc: Use image node_id 1 to create a new KafkaIOTensor object  with example: obj = KafkaIOTensor(topic, partition, servers, configuration, internal)