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. |
Classes
AutoOffsetReset (value) |
The supported offset options in Kafka |
KafkaSourceStage (config, bootstrap_servers) |
Load messages from a Kafka cluster. |