Hello Renato, Could you paste your console consumer command here?
Guozhang On Fri, May 22, 2015 at 9:43 AM, Naveen S <navg...@gmail.com> wrote: > 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 > > > -- -- Guozhang
