That's cool. In case you haven't seen this blog post [1], it provides an extended discussion of the uses of this abstraction. One comment about the groups API

That's cool. In case you haven't seen this blog post [1], it provides an extended discussion of the uses of this abstraction. One comment about the groups API is that while it is very convenient, it seems a bit fragile - if a consumer is nuked immediately after it gets a fresh batch from redis then this batch is lost forever. [1] https://engineering.linkedin.com/distributed-systems/log-what-every-software-engineer-should-know-about-real-time-datas-unifying https://engineering.linkedin.com/distributed-systems/log-wha....