Hi Dawid,
Thank you for your answer. I suspected the same and was about to try to
follow the calls to verify it. You save me some time.
I guess it might be early to tell, but if you would know in which flink and
Ververica platform version this would become available, and when, I'm off
course
Hi,
I am afraid passing of these options is not supported in SQL yet. I
created FLINK-21229 to add support for it.
In a regular job you can construct a schema registry client manually:
RegistryAvroDeserializationSchema
deserializationSchema = new RegistryAvroDeserializationSchema<>(
Hello,
I'm trying to us Flink SQL (on Ververica Platform, so no other options than
pure Flink SQL) to read confluent avro messages from Kafka, when the schema
registry secured via SSL.
Would you know what are the correct properties to setup in the kafka
consumer config?
The following options
