Lars Bachmann created FLINK-22478:
-------------------------------------
Summary: confluent schema registry avro (de)serialization https
support
Key: FLINK-22478
URL: https://issues.apache.org/jira/browse/FLINK-22478
Project: Flink
Issue Type: Improvement
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Reporter: Lars Bachmann
Currently the _ConfluentRegistryAvroSerializationSchema_ and
_ConfluentRegistryAvroDeserializationSchema_ do not support to access the
confluent schema registry via https. __ There is no possibility to provide the
required schema registry properties (keystore path, keystore pwd, ...) to the
_CachedSchemaRegistryClient_ which takes care of the necessary http(s) requests
between flink and the schema registry.
To solve this I want to add additional factory methods to
_ConfluentRegistryAvroSerializationSchema_ and __
_ConfluentRegistryAvroDeserializationSchema_ which accept and delegate the
required properties to the __ _CachedSchemaRegistryClient._
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
