[KAFKA-6864] null is not passed to keyDeserialzer and valueDeserializer in Fetcher

• Type: Bug
• Status: Patch Available
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.1.0
• Component/s: consumer
• Assignee: Unassigned
• Reporter: Mathias Kub
• Created: 04/May/18 14:36
• Updated: 25/Mar/20 16:21

Description

Hi,

currently null values are not passed to the keyDeserializer and valueDeserializer in the Fetcher class. This prevents custom deserialization of null values.

The Deserializer JavaDoc says

/**
* Deserialize a record value from a byte array into a value or object.
* @param topic topic associated with the data
* @param data serialized bytes; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.
* @return deserialized typed data; may be null
*/
T deserialize(String topic, byte[] data);

so as for my understanding, null values should be passed to it.

 

Thanks,

Mathias

Issue Links

• links to: GitHub Pull Request #4969