map async

Hello, Do you have any plans implementing map async for samza container ? This can be very useful and I suppose not very hard to implement...

SystemConsumer questions

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 o