- implement KafkaWriter