This PR fixes a bug in the custom implementation of the KafkaAvroDeserializer that treated all incoming records as GenericRecords. The fix now deserializes incoming records using the respective class of the object specified when creating the deserializer.
Changes:
KafkaAvroDeserializer is implemented with a generic type, allowing it to deserialize based on the given class passed into a new Consumer Configuration property
Adds fallback to using the Object class if no class is given (used with GenericRecords)
Bumped beta version of package
Updated and bumped version of producer and consumer examples
This PR fixes a bug in the custom implementation of the
KafkaAvroDeserializerthat treated all incoming records asGenericRecords. The fix now deserializes incoming records using the respective class of the object specified when creating the deserializer.Changes:
KafkaAvroDeserializeris implemented with a generic type, allowing it to deserialize based on the given class passed into a new Consumer Configuration propertyObjectclass if no class is given (used withGenericRecords)