You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Chris Riccomini (JIRA)" <ji...@apache.org> on 2013/10/21 20:06:42 UTC

[jira] [Created] (SAMZA-59) Support dropping messages on serde failures

Chris Riccomini created SAMZA-59:
------------------------------------

             Summary: Support dropping messages on serde failures
                 Key: SAMZA-59
                 URL: https://issues.apache.org/jira/browse/SAMZA-59
             Project: Samza
          Issue Type: Bug
            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#6144)