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
moved WatchCursorItem to the facade class
continued development work on Kafka consumer group watch functionality
reorganized the commands by category
moved the class