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
