[BEAM-9329] Support request of schemas by version on KafkaIO + Confluent Schema Registry

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.20.0
• Component/s: io-java-kafka
• Assignee: Ismaël Mejía
• Reporter: Ismaël Mejía
• Created: 17/Feb/20 16:44
• Updated: 24/Jul/20 19:57
• Resolved: 26/Feb/20 10:46

Description

BEAM-7310 introduced support to get Avro Schemas from Confluent Schema Registry as part of KafkaIO. By default it always takes the latest (most recent) version of the Schema. It would be nice to allow users to also request specific versions of the Schema.

Issue Links

• depends upon: BEAM-9364 Refactor KafkaIO to use DeserializerProviders
• links to: GitHub Pull Request #10962