Merge pull request #670 from pyr/feature-write-kafka