Refactor to use commons kafkautils
QueriesFromStream and ColumnsFromStream throw exception annotations
Modify kafka and zookeeper port parameters to Int