tfio.kafka.KafkaOutputSequence

View source on GitHub

KafkaOutputSequence

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.

Methods

flush

View source

Flush the KafkaOutputSequence.

setitem

View source

Set an indexed item in the KafkaOutputSequence.

Args
index An index in the sequence. The index tensor must be a scalar.
item the item which is associated with the index in the output sequence. The item tensor must be a scalar.