We have discussed this, and it is something that we want to look into. Do you have any thoughts on how to implement this feature? I assume you would want the failure behavior to be configurable.
Like Drop the message, Send a message to a new queue, and drop. Fail the container (is that ever appropriate?) Anything else? I am not familiar with this code base. Do you have a suggestion on what classes I should be looking to modify? Is there someone who I should bounce ideas off of? Thanks Danny On Tue, Jan 21, 2014 at 9:52 PM, Jakob Homan <[email protected]> wrote: > It's not intentional, error handling just hasn't been added yet. If you're > interested, we'd love to have the contribution. In particular, take a look > at SAMZA-59 (https://issues.apache.org/jira/browse/SAMZA-59), which also > touches on how serdes should handle error conditions. > > Thanks, > Jakob > > > On Tue, Jan 21, 2014 at 6:14 PM, Danny Antonetti > <[email protected]>wrote: > > > I am currently using the JsonSerde/JsonSerdeFactory classes for > serializing > > kafka messages. > > > > I have noticed that if there is bad json input coming in through kafka, > the > > samza container seems to crash. > > > > I was looking at JsonSerde.scala, which does not seem to have any error > > handling. > > > > So I was curious if this was intentional? > > Or if there is a different way to handle these types of input errors? > > > > > > Thanks > > > > > > Danny > > >
