[Bug] Workload does not terminate if backlog fails to drain

[teabot]

I have observed a situation where the consumer is unable to fully drain the backlog, but does reach a steady state. In this scenario, the test does not terminate at the expected time, but continues indefinitely.