Thanks for the input guys!
Yes, I did get that the 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 as an o
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, Y
Hello Renato,
Could you paste your console consumer command here?
Guozhang
On Fri, May 22, 2015 at 9:43 AM, Naveen S wrote:
> Hey Renato,
> Is there any specific reason why you are extending the
> blocking envelope class instead of implementing a StreamTask ?
> http://samza
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 <
renatoj.m
