NVIDIA Morpheus (24.10.01)

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 2024, NVIDIA. Last updated on Dec 3, 2024.