52b43c40bc
Instead of looping and polling a fresh set of partitions and constructing a stream from that, use an endless stream instead. This helps w/ efficiency during roll-overs since we can already start to process the next set of partitions while the last ones from the previous round are still in-progress. Closes #6750. Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com> |
||
---|---|---|
.. | ||
src | ||
Cargo.toml |