Feature/use reader schema for specific records

Open AFrieze opened this issue 8 years ago • 1 comments

The KafkaAvroDeserializer uses the writer schema retrieved from the incoming message to deserialize messages into GenericRecords. This leads to default values in a newer Reader schema being ignored. This PR adds a new deserializer that is configured with the appropriate reader schema based off a source. It is worth noting that this PR removes the getQueue(String name) and getTopic(String name) from the ForkliftConnector interface.

Nov 20 '17 23:11 AFrieze

It looks like we forced this into develop. @Kuroshii @AFrieze can this PR be closed?

Jul 17 '20 03:07 dcshock