samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Raj raj <rajlistu...@gmail.com>
Subject Re: Catching exceptions from serde
Date Wed, 23 Nov 2016 13:39:54 GMT
Thanks for the reply Jagadish.

On Tue, Nov 22, 2016 at 10:58 PM, Jagadish Venkatraman
<jagadish1989@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

Mime
View raw message