Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-22478

confluent schema registry avro (de)serialization https support

    XMLWordPrintableJSON

    Details

      Description

      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.

       

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              qingdao81 Lars Bachmann
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - 2h
                2h
                Remaining:
                Remaining Estimate - 2h
                2h
                Logged:
                Time Spent - Not Specified
                Not Specified