You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Noel OConnor <no...@gmail.com> on 2022/12/13 14:40:31 UTC

convert DataStream to DataStream

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