Re: Need Help with Samza

Hi, Ramesh, Could you share the exact stack trace and the job configuration, especially the Kafka producer configuration for the changelog system? Thanks! -Yi On Thu, Feb 4, 2016 at 11:56 AM, Ramesh Bhojan wrote: > Dear team @ Samza, > I would really appreciate some help with the following qu

Re: Samza Throttling clarification

Hi Ramesh, I understand that you want to limit the calls to the destination service. Currently, there's no framework level support for throttling in Samza (yet). But, since Samza is single threaded, you can trivially implement some form of throttling by calling Thread.sleep() in the StreamTask.pro

Re: Samza Throttling clarification

Can I ask why you’re using samza and kafka for this? > On Feb 4, 2016, at 7:41 PM, ramesh shanmugam > wrote: > > Hi Team, > > We have use case that destination system accept only 160 messages per > minute. > > Planning to use Samza with Kafka. Looking for out of box throttling feature > but

Samza Throttling clarification

Hi Team, We have use case that destination system accept only 160 messages per minute. Planning to use Samza with Kafka. Looking for out of box throttling feature but not able locate in documenttion. Can you please suggest how throttling can be achieved in Samza?. -- Thanks Ramesh

Need Help with Samza

Dear team @ Samza, I would really appreciate some help with the following question posted in Stack Overflow : http://stackoverflow.com/questions/35168641/is-there-a-configuration-setting-to-allow-large-values-in-my-samza-store Thanks, Ramesh