Classes
ControlMessageKafkaSourceStage(c, ...[, ...]) |
Load control messages from a Kafka cluster. |
morpheus.stages.input.control_message_kafka_source_stage
Previous
morpheus.stages.input.control_message_file_source_stage.ControlMessageFileSourceStage
Next
morpheus.stages.input.control_message_kafka_source_stage.ControlMessageKafkaSourceStage