This is a workaround class for the issue when a record cannot be deserialized from Avro, and there is no possibility to get past this record, since consumer continues receiving it repeatedly.
| Type Params | Return Type | Name and description |
|---|---|---|
|
java.lang.Object |
deserialize(java.lang.String s, byte[] bytes) |
|
java.lang.Object |
deserialize(java.lang.String s, byte[] bytes, Schema readerSchema) |