Hi Dominik,
If I understand the scenario correctly, I think one possible solution
is to implement one specified TwoInputStreamOperator directly, and also
implements the InputSelectable interface. Then this operator could control the
priority its two inputs by return proper InputSele
Hey,
I have a question since I have observed the following situation:
We have two streams A and B that will be read from Kafka. Let's say we
have a set of rules for processing that is stored in A and B is the stream
that we will process.
Since there is no guarantee that elements from A will be pr
