Hi, I'm reading from a kafka topic and performing some custom AVRO deserialisation but now I want to create a change log stream from the source kafka topic.
I'm currently creating a temporary view and then selecting * from that and finally changing the resultant table to a change log stream via the toChangeLogStream. This all works but I was wondering if there was a better way. cheers Noel