architecture for sparse data flows over kappa-core driven by peer queries - View it on GitHub