Stateful Stream Processing

[lzwaan]

Some questions:

1. How to start from the latest offset?
2. Is it possible to use it for stateful streaming processing and recover from failures?

[rustyconover]

That's all pending functionality, if you're interested in sponsoring development, contact me.