[
https://issues.apache.org/jira/browse/BEAM-9364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-9364:
-------------------------------
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). (was: 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).)
> Refactor KafkaIO to use DeserializerProviders
> ---------------------------------------------
>
> Key: BEAM-9364
> URL: https://issues.apache.org/jira/browse/BEAM-9364
> Project: Beam
> Issue Type: Improvement
> Components: io-java-kafka
> Reporter: Ismaël Mejía
> Assignee: Ismaël Mejía
> Priority: Major
>
> 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).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
