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

Reply via email to