Hello everyone, I have a kafka topic where same user’s data goes to the same partition. I want to prepare a simple running aggregate like count for each user in flink. How should I write the flink job so that there is no or less data shiffle? What else I can do to optimize the application and ready for scaling when we have a lot of users and data?