I am working on consuming data from a Kafka topic in RisingWave, and encountering an error related to Avro schema. I have provided sample code snippets and error messages. The Flink SQL equivalent works fine. What could be causing this error?
Sandip Nayak
Asked on Apr 15, 2024