removed unused trait
cleaning up dependencies - removing unused / updated to latest versions
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