[FLINK-22858] avro-confluent doesn't support confluent schema registry that has security enabled

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.13.1
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
• Assignee: TAO XIAO
• Reporter: TAO XIAO
• Created: 02/Jun/21 15:48
• Updated: 03/Jun/21 07:09
• Resolved: 03/Jun/21 07:09

Description

Schema registry supports HTTP authentication via configuration[1] however avro-confluent doesn't pass format options to schema registry client which results in no authentication connection to schema registry only. To fix this we can pass the format options to CachedSchemaCoderProvider.java

 

[1]https://github.com/confluentinc/schema-registry/blob/master/schema-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaSchemaSerDeConfig.java#L85

Issue Links

• causes: FLINK-22763 avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry
• duplicates: FLINK-21229 Support ssl connection with schema registry format