Initial commit of Kafka FS producer