Hello HN,<p>We use PubSubLite but the same can be applied to any queue system. The events are then processed by service running in K8S.<p>I am looking for strategies/patterns on how do folks partition their data so that each worker unit can get consistent performance with optimal CPU/memory usage.<p>Our data is global and temporal i.e. different regions will have peak/off peak data volume based on their time zones.<p>We have done performance test and we know how many events / second / partition we can process per worker units.<p>The issue we are currently facing is that when we get auto assigned partitions and based on randomness, we can get multiple heavy traffic partitions thus causing resource contention at a worker and causing slowdown.<p>Some options we have considered:<p>* running one worker unit per partition - this results in wastage as we have to use constant resources even in off peak time. this also results in using coordinater to make sure everybody is subscribing to correct partitions.<p>* group tenants into their traffic size and setup workers based on that. This has side effect of again extra maintenance on our side and bit of coordination with tenant provisioning/deprovisioning.<p>* order traffic to certain partitions based on tenant_id but then some partitions become too big and others dont.<p>What other strategies you use?