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. |
NVIDIA Morpheus (25.02.01)
Previous
morpheus.stages.input.in_memory_source_stage.InMemorySourceStage
Next
morpheus.stages.input.kafka_source_stage.AutoOffsetReset