Thanks everybody!
This is super useful!
Louisia
>From Jagadish Venkatraman
Subject Re: Send a msg to all partitions
Date Sat, 19 Mar 2016 02:12:55 GMT
The incoming message envelope that you receive has methods to look up what
system or stream partition it is from. So you can choose to re
Broad cast stream is the Samza feature designed for this exact requirement.
Your thinking is on the right lines.
Please take a look at task.broadcast.inputs from the Samza configuration
reference page.
On Friday, March 18, 2016, Louisia Famalda
wrote:
> Hi,
>
> I'm new to Samza and I'm trying t
Hi,
I'm new to Samza and I'm trying to do this:
>From my standalone app, I'm writing some ActionEvents to a Kafka topic with
5 partitions
>From Samza, I want to process those events but I need to send some filters
information on how to process those events.
For example, I want to keep all message
The incoming message envelope that you receive has methods to look up what
system or stream partition it is from. So you can choose to react
differently if this message is from a broadcast stream.
Let us know if you need more help!
On Friday, March 18, 2016, Jagadish Venkatraman
wrote:
> Broa
