Can we make a kafka topic as KV store globally to all tasks, not partitioned? For example, we have a kafka topic "cache" and it has a 4 partitions. If we launch a container with 4 tasks, each task will have one partition of "cache" kafka topic and create a KV store instance. I want to make all 4 partitions in "cache" topic available in all tasks.
On Mon, May 2, 2016 at 11:26 PM, Jagadish Venkatraman < jagadish1...@gmail.com> wrote: > Hi, > > What do you mean by broadcasted KV storage? Currently a KV store instance > is specific to a task. Are you referring to broadcast streams? > > > > On Mon, May 2, 2016 at 7:58 PM, Bae, Jae Hyeon <metac...@gmail.com> wrote: > > > Hi Samza devs and users > > > > Is it possible to implement broadcasted KeyValueStorage with 0.9? I know > > 0.10 supports broadcast but we're not yet to 0.10. > > > > Thank you > > Best, Jae > > > > > > -- > Jagadish V, > Graduate Student, > Department of Computer Science, > Stanford University >
