morpheus.stages.input.kafka_source_stage

Classes

AutoOffsetReset(value) The supported offset options in Kafka
KafkaSourceStage(config, bootstrap_servers) Load messages from a Kafka cluster.
Previous morpheus.stages.input.in_memory_source_stage.InMemorySourceStage
Next morpheus.stages.input.kafka_source_stage.AutoOffsetReset
© Copyright 2023, NVIDIA. Last updated on Feb 2, 2024.