Maciej Mensfeld

ref https://github.com/karafka/waterdrop/issues/243

```ruby topic :test do virtual_partitions( active: true, partitioner: ->(_) { rand } ) long_running_job( active: true ) end ```

ref https://github.com/karafka/karafka/issues/1010 we can easily add this based on the integration specs: https://github.com/karafka/karafka/blob/master/spec/integrations/instrumentation/statistics_on_lag_with_many_sub_group.rb

Rebalance with static group membership and LRJ should not cause double processing on paused topics

Within the same subscription group, if we have an LRJ and a non LRJ, the non LRJ may cause the kickout despite second being in LRJ.

I want to be able to say "hey, process this topic data but make sure that the data that were working with is at least X seconds/minutes/hours" old. This will...

We are getting more end states of processing with each new option (like DLQ). Would be good to isolate states so we can easily handle and test each instead of...