NVIDIA Morpheus (25.02.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 Mar 3, 2025.