samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: Not able to consume produced data
Date Fri, 22 May 2015 16:59:51 GMT
Hello Renato,

Could you paste your console consumer command here?

Guozhang

On Fri, May 22, 2015 at 9:43 AM, Naveen S <navgog8@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.marroquin@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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message