Midway through I realized they're reinventing solved problems already.
Mixpanel should take a look at Apache Iceberg for your writing and Apache Pulsar to keep your cost lower by not needing to keep 7 day retention in your pipeline once the messages are ack'ed by all consumers.
For replaying you can use Trino to just read from your Iceberg and insert back into your stream.