[ 
https://issues.apache.org/jira/browse/FLINK-22478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332969#comment-17332969
 ] 

Lars Bachmann commented on FLINK-22478:
---------------------------------------

[~twalthr] that is correct - it is a duplicate of FLINK-21229. Yes please 
assign me the other ticket and I will do the contribution. Thanks!

> 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)

Reply via email to