Unsubscribe

Unsubscribe, Regards, Olga Gorun

pyflink: problem with temparal join and kafka connector with avro-confluent format

Hi Flink team, I am trying to use temporal join with two kafka-based streams ("tables"), where the key is formatted as JSON and value - confluent schema registry-based Avro. On joining I get the error: "*The Kafka table 'default_catalog.default_database.sensor_readings' with 'avro-confluent' forma