[BEAM-9364] Refactor KafkaIO to use DeserializerProviders

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.20.0
• Component/s: io-java-kafka
• Assignee: Ismaël Mejía
• Reporter: Ismaël Mejía
• Created: 24/Feb/20 07:39
• Updated: 24/Jul/20 19:57
• Resolved: 25/Feb/20 13:15

Description

BEAM-7310 introduced support for Confluent Schema Registry, even if the API did not explicitly mention DeserializerProviders it opened the option to use multiple providers of Deserializers. The goal of this ticket is to refactor the KafkaIO API to reflect this new concept both for local Deserializer resolution and Confluent Schema Registry based (notice that this one becomes better isolated).

Issue Links

• is depended upon by: BEAM-9329 Support request of schemas by version on KafkaIO + Confluent Schema Registry
• links to: GitHub Pull Request #10947