Hi Tao, Thanks for reaching out. Have you tried the following
'value.avro-confluent.schema-registry.url' = 'https://{SR_API_KEY}:{SR_API_SECRET}@psrc-lzvd0.ap-southeast-2.aws.confluent.cloud', It may be possible to provide basic HTTP authentication by adding your username and password to the URL. There is already a similar ticket open unfortunately without much progress. [1] Please let me know if this works for you otherwise we can try to find a different solution. Best, Fabian [1] https://issues.apache.org/jira/browse/FLINK-22763 > On 2. Jun 2021, at 10:58, tao xiao <xiaotao...@gmail.com> wrote: > > Hi team, > > Confluent schema registry supports HTTP basic authentication[1] but I don't > find the corresponding configs in Flink documentation[2]. Is this achievable > in Flink avro-confluent? > > > [1]https://docs.confluent.io/platform/current/confluent-security-plugins/schema-registry/install.html#authentication-mechanisms > > <https://docs.confluent.io/platform/current/confluent-security-plugins/schema-registry/install.html#authentication-mechanisms> > [2]https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/formats/avro-confluent/#format-options > > <https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/formats/avro-confluent/#format-options>-- > > Regards, > Tao