implemented querying for Kafka via BDQL
fixed query parsing issue
extracted StreamedMessage into its own class, and added partition and offset to the query output
Merge branch 'develop' into scala_2.11

* develop:
  extracted StreamedMessage into its own class, and added partition and offset to the query output
  fixed query parsing issue
  implemented querying for Kafka via BDQL