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.marroq...@gmail.com> wrote:
> Hi there,
>
> I have developed an RSS reader application using Samza but I am having
> problems when using kafka-console-consumer to read what has been gotten
> from the RSS feeds.
> My RssConsumer uses an object RssFeed which fetches (until stopped by the
> RssConsumer) all new rss feeds and hands them back to the RssConsumer which
> puts them into a single partition[2]. So from my logs I can see that there
> are new feeds being put into my partition but I can not get them with
> consoler consumer, I guess I am not putting them correctly or I am
> producing some blocking behaviour somehow?
> I using hello-samza 0.10 project which uses the latest Samza version as
> well. I don't think this is an issue with Samza, it is probably something I
> am doing wrong :(
> Thanks in advance for any suggestions.
>
>
> Renato M.
>
> [1] https://github.com/renato2099/hello-samza
> [2]
>
> https://github.com/renato2099/hello-samza/blob/master/src/main/java/samza/examples/rss/system/RssConsumer.java#L42
>
