morpheus.stages.input.kafka_source_stage

(Latest Version)

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 2024, NVIDIA. Last updated on Jul 8, 2024.