Hello, 1) I need stateful SystemConsumer, similar to tasks functionality : https://samza.apache.org/learn/documentation/0.9/container/state-management.html is there some reason why it is not implemented for SystemConsumer?
2) SystemConsumer has *register* method, which receives stream offset as parameter - is that offset for output streams. Why do I need that offset then? If it is for input streams then which part actually reads messages from kafka. Is there any sample code how to use that offsets? Thanks Ivan
