Classes
WriteToKafkaStage(c, bootstrap_servers, ...)
WriteToKafkaStage
Write all messages to a Kafka cluster.