Hi everyone, I've just started using Samza, so pardon me if my questions are obvious.
I've looked through the example hello-samza. So here are some questions I have when trying to write an application on Samza: 1) I can't seem to figure out how to define the number of partitions for a stream. 2) Will a StreamTask stop? (when its input streams are all exhausted). How to trigger this and stop the task when all messages are processed? Thanks a lot, guys! Casey
