Fwd: Re: Failed to create a consumer

exception. It is fixed now. Rgds, Marcelo -- *From:* Jagadish Venkatraman *To:* dev@samza.apache.org; Marcelo Romaniuc *Sent:* Tuesday, December 29, 2015 5:26 AM *Subject:* Re: Failed to create a consumer Hi Marcelo, *task.inputs=product.product.txt* The for

Re: Failed to create a consumer

Hi Marcelo, *task.inputs=product.product.txt* The format of this property task.inputs is system_name.stream_name, for example - kafka.PageViewEvent. You've defined your own system called *product* with a custom *FileFeedSystemFactory*. It seems like there was an exception in your FileFeedSystemF