I have stream of data such as JSON records with an ID.
I would like to process the data such that all records with the same key are processed by the same stateful task.
How can I do that?
I have stream of data such as JSON records with an ID.
I would like to process the data such that all records with the same key are processed by the same stateful task.
How can I do that?