Schema Validation with Pyflink and Kafka’s Schema Registry
I was able register my expected schema for the Kafka topic for the records arriving using the below command:
I was able register my expected schema for the Kafka topic for the records arriving using the below command: