morpheus.stages.input.kafka_source_stage

Classes

`AutoOffsetReset`(value)	The supported offset options in Kafka
`KafkaSourceStage`(c, bootstrap_servers[, ...])	Load messages from a Kafka cluster.