Thanks for the input guys!
Yes, I did get that the consumer would be putting data into Samza. So
maybe I am not understanding something else :(
I have a RssSystemFactory which creates a RssConsumer (which
extends BlockingEnvelopMap and which in turn extends SystemConsumer). This
RssConsumer acts
Hey Renato,
Is there any specific reason why you are extending the
blocking envelope class instead of implementing a StreamTask ?
http://samza.apache.org/learn/documentation/0.9/api/overview.html
--Naveen
On Fri, May 22, 2015 at 8:06 AM, Renato Marroquín Mogrovejo
Hi Renato,
There maybe a misunderstanding in the concept. Consumer is to feed the msgs
into the Samza, while Producer is to send the msg from Samza to other
systems. So if you implement the Consumer, should be able to see the msgs
in the StreamTask. That's why you confuse Naveen.
Cheers,
Fang,
