Yeah, we don't support this at the moment. The imminent SAMZA-123 patch allows this, but we're disabling it for another JIRA so we can think through all the repercussions (state, metrics, failure, etc.).
-Jakob On Tue, Jul 22, 2014 at 12:02 PM, James Jory <[email protected]> wrote: > I have a job that consumes a stream with multiple partitions and the work > is divided amongst multiple StreamTask instances as you’d expect. Now I > need to be able to synchronize some state to all of my StreamTasks that is > used to process messages from this stream. That is, the same state lives in > every StreamTask instance. I was going to do this via a second stream but I > need the messages in this stream to be broadcast to every StreamTask > instance. It appears, though, that Samza doesn’t support the broadcast > model for input streams. I could workaround this by writing each message to > all partitions but wanted to see if there was a better way of solving this > problem. > > Thanks! > James
