samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Raj raj <>
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
<> wrote:

> If you are okay with dropping messages when there are ser-de errors, please
> take a look at :
> task.drop.deserialization.errors


> 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,


View raw message