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 >
