Module: tfio.kafka

View source on GitHub

Kafka Dataset.

Classes

class KafkaDataset: A Kafka Dataset that consumes the message.

class KafkaOutputSequence: KafkaOutputSequence

Functions

decode_avro(...)

decode_avro_init(...)

encode_avro(...)

write_kafka(...): Args: