I built this because we needed a way to manage tons of independent FIFO partitions for some of our products. It includes consumer groups, replay capabilities, and transactional delivery—all ACID-guaranteed by Postgres.
I'd love to hear your thoughts on the architecture or if you have any questions about how the partitioning is implemented under the hood!