Fork me on GitHub
Ben Sless16:10:56

Does group-by come with any mechanism for handling potentially unbounded key space?


yes, cancelling a consumer will free up the key

Ben Sless16:10:27

So for each consumer I'll need to create a race between a sleep and the potential downstream consumer? A new consumer process will be recreates if the key returns, right?