testing the new streaming message consumer
refactoring test class
added test constraint
added method to close the stream
added scan method for searching for messages by key
updated the extension
added logging messages
clarifying method declaration
moved scope variable
added method to support searching for messages by key
IDE code reformatting
annotated exception with more meaningful information
removed the necessity to pass to commandSet
extended the wait time for futures
added convenience methods for converting partition and offset strings to Int and Long respectively
IDE code reformatting
added logger instance
resolve logging conflicts with Log4j and SLF4j
added type parameter
added preliminary VScript support