morpheus.stages.input.kafka_source_stage

Classes

AutoOffsetReset(*values)	The supported offset options in Kafka
KafkaSourceStage(config, bootstrap_servers)	Load messages from a Kafka cluster.