Hi All! Excuse my stupid question, I am pretty new to the Table/SQL API and I am trying to play around with it implementing and running a few use-cases.
I have a simple window join + aggregation, grouped on some id that I want to write to Kafka but I am hitting the following error: "AppendStreamTableSink requires that Table has only insert changes." If I understand correctly the problem here is that since updates are possible within a single group, we have a retract stream and the Kafka Sink cannot handle that. I tried to search for the solution but I haven't found any satisfying answers. How can I simply tell the INSERT logic to ignore previous values and just always keep sending the latest (like you would see it on the CLI output). Thank you! Gyula
