Thanks for the reply Jagadish. On Tue, Nov 22, 2016 at 10:58 PM, Jagadish Venkatraman <jagadish1...@gmail.com> wrote:
> If you are okay with dropping messages when there are ser-de errors, please > take a look at : > task.drop.deserialization.errors Ok. > Also, you probably want to fix the problem at the source you're consuming > from (on why it was generating invalid messages) Yes, that is what I wanted to find out. Ideally I want to log the incoming message with error to the log so that I can figure out what is wrong. I am sending (supposedly) valid json messages to the input. with regards, raj
