Send kafka message to hdfs using api not mapreduce