Classes
AutoOffsetReset(value) |
The supported offset options in Kafka |
KafkaSourceStage(config, bootstrap_servers) |
Load messages from a Kafka cluster. |
morpheus.stages.input.kafka_source_stage
Previous
morpheus.stages.input.in_memory_source_stage.InMemorySourceStage
Next
morpheus.stages.input.kafka_source_stage.AutoOffsetReset