Module: tfio.kafka

View source on GitHub

Kafka Dataset.

Classes

class KafkaDataset: A Kafka Dataset that consumes the messages.

class KafkaOutputSequence: KafkaOutputSequence

Functions

decode_avro(...)

decode_avro_init(...)

encode_avro(...)

write_kafka(...): Write messages to the kafka topic