updated author
addressing issues with specifying the partition using the "-p" flag
the configuration file will now be auto-created
kprev and knext now allow overflow to previous/next partition
added module helper singleton
fixed test issues
added support for streamed messages
added a generic Ok class for acknowledgements
updated to use the new Zookeeper client
optimized imports
updated the consumer to use a connection string
clarified variable
added new watch methods to return results as they are streaming
added new watch cursor
clean up
created a new trait representing binary messages
created (and implemented) a new trait representing binary messages
removed unnecessary close method
renamed avroSchema to avroCodec
implemented Avro decoding for watched messages