The backpressure fix is to place a semaphore in front of the executor, where consumers only commit a Kafka message and start a graph run after acquiring a slot, release the slot and exponentially back off to return the message on receiving a 429, and temporarily lower the semaphore limit.