morpheus.stages.output.write_to_kafka_stage# Classes WriteToKafkaStage(c, bootstrap_servers, ...) Write all messages to a Kafka cluster.