Forked of Streamz to deliver processed guarantees at least once for Kafka consumers with extra features. - View it on GitHub