reads from stdin and writes to two topics - firehose and ten-percent
reads from stdin and writes to zips files after a configurable number of messages are received
spits put canned twitter tweets at a configurable rate
watches a directory and copies any new zip files to S3