Re: FlinkKafkaProducer - Avro - Schema Registry

2022-04-07 Thread Dan Serb
to have the producer properties together with the KafkaAvroSerializer still, for me to force the serialization to go through Schema Registry. Regards, Dan Serb On 08.04.2022, 05:23, "Qingsheng Ren" wrote: Hi Dan, In FlinkKafkaProducer, records are serialized by the Seriali

FlinkKafkaProducer - Avro - Schema Registry

2022-04-05 Thread Dan Serb
t least some points where I could investigate more and if there is someone else that has a similar implementation, maybe some tips and tricks. Regards, Dan Serb

[Table API] [JDBC CDC] Caching Configuration from MySql instance needed in multiple Flink Jobs

2022-02-21 Thread Dan Serb
use in my situation, this is the reason why I’m asking users that might have more experience with this and that might have had the same issues sometime in the past. Thank you in advance, guys! Regards, Dan Serb