A json schemaless stream querying engine that would run several sql queries over the same kafka consumer (not a consumer for each query).