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
ev/table/connectors/kafka.html
[2]https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/jdbc.html
[3]https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/streaming/joins.html
Best,
Guowei
On Wed, Nov 18, 2020 at 3:05 PM tkg_cangkul <mailto:yuza.ras...@gm
Hi Guowei Ma,
Thanks for your reply,
In my case.
I've some data on my kafka topic. and i want to get the detail of the
data from my reference mysql table.
for example :
in my kafka topic i've this fields :
id, name, position, experience
in my reference mysql table i've this fields:
id, name
