Hi, Chas, Could you share your job configuration as well?
Thanks! -Yi On Mon, Jun 8, 2015 at 8:42 AM, Chas Personal <c.peza...@hotmail.com> wrote: > Hello, > > > > I am working on a Samza script currently and had a couple questions. I am > able to work with the Hello-Samza application and have been able to add to > that example. The goal is to be able to write one from scratch and be able > to implement and iterate upon it indefinitely. The questions I have are the > following. > > > > I understand the StreamTask handles the logic. I can create a StreamTask > that just consumers and produces raw data but where my problem comes in is > with the consumer. The Wikipedia example connects to an IRC in order to > have a stream of constant data. Instead of connecting to IRC in my consumer > I am aiming to connect to a zookeeper connection that listens to an input > Kafka topic. Is there an example somewhere to see how to implement this, or > any direction? I understand the flow, I believe, am just struggling with > the code implementation. > > > > Second question is an error that I am having which may be solved by a > solution to the above inquiry. I am receiving an error saying “Failed to > update metadata after 98 ms.” I’ve attached a txt document with a log of > the information if you can provide any assistance. > > > > Apologies for the probably obvious questions but I am really wanting to > fully understand this whole system so I can manipulate it to my liking > soon. > > > > Thank you, > > Chas Pezanko > > > > > > >
