[
https://issues.apache.org/jira/browse/SAMZA-59?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13895362#comment-13895362
]
Danny Antonetti commented on SAMZA-59:
--------------------------------------
I have added my patch to review board here
https://reviews.apache.org/r/17869/
> Support dropping messages on serde failures
> -------------------------------------------
>
> Key: SAMZA-59
> URL: https://issues.apache.org/jira/browse/SAMZA-59
> Project: Samza
> Issue Type: Bug
> Components: container
> Reporter: Chris Riccomini
>
> Samza uses the Serde interface to serialize and deserialize messages when
> producing and sending them.
> Right now, if a Serde is unable to (de)serialize a message, it has no choice
> but to throw an exception, or put some non-standard surrogate object in the
> message envelope's key/value fields. If an exception is throws, the whole
> container fails.
> We should make it possible for Serdes to signal to Samza that they were
> unable to (de)serialize the message in question, and add configuration to
> Samza to be able to drop these messages rather than throwing an exception.
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
