Hi all, I have a StreamTask that uses *JsonSerde* to parse the input from a Kafka topic. I notice that when the input is not a valid json, the task fails with an exception on json parsing. If I use
*task.drop.deserialization.errors=**true* in the configuration then the malformed json will be dropped silently and the task goes on to the next message. Is there a way for the task to report the deserialization error but not fail? Thanks, Jack Huang
