I have a query that joins two Kafka topics to insert into a flinke table. The type of join is Inner join.
How does Flinke process the stream? would it process the output irrespective of changes in left or right table or are there additional considerations.