Hi, Jack,
There have been asks similar to yours, like SAMZA-427. As fixed in
SAMZA-59, we also included metrics to report the count of deserialization
errors. If you are asking about the actual message that caused the error to
be reported, there has to be a different way. Options are:
1) write the
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 dr
