...

We could set the first approach as the default policy, while the second approach (which is the one that Samza uses) would be used only if the client specifies us to use more than one thread per stream task.   However, the second policy could potentially have some tradeoffs in that ordering would no longer guaranteed (like offset numbers are out of order).  

Proposed Changes

Changes to Processor API TBD.

...