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
