- Implement KafkaWriter