Есть ли способ реализовать небольшой разъем mapreduce для передачи файлов из HDFS в Kafka? Как написать такую программу или функцию? Спасибо