Open fdelbrayelle opened 4 years ago
@pascalgrimaud Not reproduced because it's linked with Avro and schema registry that are not yet implemented in the module. It could be done in a near future (see #63).
Let's keep open the issue for this purpose.
PR #65 will partially resolve this issue which should be kept opened to deal with the Avro case later.
The goal is to anticipate the consumption of poisonned data which could lead to an
Exception
, an logged error and to close the consumer without to know what is the poisonned data.See: https://jonboulineau.me/blog/kafka/dealing-with-bad-records-in-kafka