Ismaël Mejía created BEAM-9364:
----------------------------------
Summary: 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
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)
