[ https://issues.apache.org/jira/browse/FLINK-22478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332484#comment-17332484 ]
Timo Walther commented on FLINK-22478: -------------------------------------- [~qingdao81] is this a duplicate of FLINK-21229? I can assign you the other ticket. Would you like to contribute? > 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 > Priority: Minor > Original Estimate: 2h > Remaining Estimate: 2h > > 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)