How to implement something similar to Storm's DRPC in Samza?

s are welcome! -- Vladimir Lebedev http://linkedin.com/in/vlebedev

Re: How do you serve the data computed by Samza?

. Best regards, Vladimir -- Vladimir Lebedev http://linkedin.com/in/vlebedev On 03/31/2015 07:39 PM, Felix GV wrote: Hi Harlan and Vladimir, I think the idea of serving data directly off of Samza has been mentioned a few times, but there are certain caveats that make this a risky proposition. For

sending data to a different partitions of the output stream

operties, like I may do it in Kafka via partitioner.class property? Many thanks in advance, Vladimir -- Vladimir Lebedev http://linkedin.com/in/vlebedev

Re: sending data to a different partitions of the output stream

hashcode, and the hash of integers is the value itself. On 04/07/2015 07:40 AM, Vladimir Lebedev wrote: Hey, I can not find clear explanation of this in the documentation or in hello-samza: how to tell collector to send my output data to a particular partition of the output stream? My

changelog compaction problem

changelog topic. Did somebody have similar problem? How it could be resolved? Best regards, Vladimir -- Vladimir Lebedev w...@fastmail.fm