Hi!
You'll need to set
props.put("schema.registry.basic.auth.user.info",
":");
tkg_cangkul 于2021年7月21日周三 上午12:06写道：
> Hi,
>
>
> i'm trying to connect to kafka with schema registry that using SSL with
> flink 1.11.2
>
> i've got this error message when i try to submit the job.
>
> Caused by: io
Hi,
i'm trying to connect to kafka with schema registry that using SSL with
flink 1.11.2
i've got this error message when i try to submit the job.
Causedby:
io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException:
Unauthorized; error code: 401
Anyone can help me to
