[Demo] How to Build Streaming Agents with Flink, Claude LLM, & Anthropic’s MCP | Register Now

How Superwall Uses WarpStream and ClickHouse Cloud to Scale Subscription Monetization

This post was originally published on the ClickHouse blog.

Superwall is a small team doing big things. With only 14 people, the company powers paywall monetization for hundreds of mobile subscription apps that reach billions of end users.

The pitch is straightforward: Install Superwall’s software development kit (SDK) once, and you can instantly A/B test checkout flows, adjust pricing globally, and roll out discounts, all without shipping an app store update. At the heart of the platform is a focus on continuously balancing supply and demand, as co-founder and CTO Brian Anglin explains: “With digital products, usually you have high fixed costs and low variable costs. You want to be able to accept any offer without cannibalizing customers who would have paid more.”

But that type of experimentation and optimization at scale is anything but simple. Every paywall view, conversion, and experiment generates an event that must be captured, streamed, and analyzed in near-real-time. Dashboards have to update in seconds so that customers can see results. To ingest 100 MB of events per second and store 300+ TB of data, Superwall needed a stack that was fast, durable, and, perhaps most importantly, low maintenance.

We caught up with Brian to learn how Superwall landed on WarpStream and ClickHouse Cloud, how its stack has evolved over the past few years, and the missing piece that finally tied it all together.

Getting Started With Apache Kafka® and ClickHouse

When Superwall first began building its platform, the team had two main needs: a reliable data streaming backbone to handle the flood of events from its SDK and an analytical database that could make sense of those events quickly enough to power customer dashboards. “We didn't want to settle for hourly or daily rollups,” Brian says. “We wanted something near-real-time.”

On the streaming side, Apache Kafka® compatibility was important. “It really sucks to lose data, and we also make mistakes,” he says. By turning up retention, the team could replay events if something broke or reprocess data when new use cases emerged. That durability brought the confidence to move quickly.

For analytics, the team chose ClickHouse. Blog posts from PostHog and Cloudflare—including one showing how Cloudflare processed 6 million requests per second—gave Brian confidence that it could handle web-scale workloads. “I was like, ‘If their Kafka-plus-ClickHouse stack can do that, it’ll be enough for our piddly little SDK with, like, one customer,’” he jokes.

ClickHouse’s materialized views, he says, were like “magic.” Instead of writing custom jobs to update counters or roll up metrics, the team could lean on ClickHouse to pre-aggregate in real time. “When I realized I could do that with SQL, I was like, ‘Oh, this is so much easier.’”

Compression was another unexpected win, allowing the team to store huge amounts of data without jacking up costs. “I was shocked by the compression ratios we were able to achieve,” Brian says. “You don’t get that for free in any other database systems.”

The initial production stack was simple: Kafka up front and ClickHouse on a single Amazon EC2 instance behind it. “Once we had those two things working,” Brian says, “we started writing queries against it and had everything we needed to deliver a super simple minimum viable product (MVP) that was more real-time than anyone else in the space.”

Evolving With WarpStream and ClickHouse Cloud

Within a few months, however, the limits of that early stack started to show. With ClickHouse running on EC2, disk space was a constant headache. “I’d find myself over and over trying to resize the instance,” Brian recalls. “It became this background task I was always thinking about.”

The team turned to a third-party ClickHouse consulting company, which solved some problems but introduced others, including cost. “When I actually did the math about what we were paying between compute, backups, the managed service, and Amazon S3 usage in our own Amazon Web Services (AWS) account, it got really, really expensive,” he says.

During the search for a better long-term foundation, ClickHouse Cloud became the logical next step for analytics. Its separation of storage and compute promised to eliminate the endless disk resizing, while SharedMergeTree offered elastic scaling that could flex with demand. Just as important, the pricing model aligned with Superwall’s usage. “Being able to just charge my credit card and have more storage was pretty compelling,” Brian says.

On the streaming side, WarpStream (which was acquired by Confluent in September 2024) emerged as the answer. It preserved Kafka compatibility—meaning no rewrites—while introducing a Bring Your Own Cloud model that made it cheaper and easier to run at scale. “Unlike trying to run Kafka locally, I ran the little agent demo and it just worked,” Brian says. “It was so refreshing to have a Kafka-compatible API running out of the box.”

Together, ClickHouse Cloud and WarpStream offered Superwall the scalable, cost-effective, ops-light stack it needed to keep up with growth. There was only one missing piece ...

Ingesting From WarpStream to ClickHouse With ClickPipes

Before Superwall could fully migrate to the new ClickHouse Cloud-plus-WarpStream stack, it needed a reliable way to move data between the two without taking on operational overhead. Any break in ingestion risked leaving customer dashboards stale.

Superwall had previously relied on the Kafka table engine in ClickHouse open source software (OSS). However, this approach provided limited monitoring, lacked notifications, and coupled scaling to the ClickHouse server—too many gray areas. “Every time something broke, the question was always, ‘Did everything stop, or did reporting just stop?’” Brian says. Running connectors themselves wasn’t appealing either. “I just wasn’t confident we could do it perfectly.”

ClickPipes offered a much better and fully managed way. By streaming data directly from Kafka-compatible sources such as WarpStream into ClickHouse Cloud, it gave Brian and the team both durability and peace of mind. Invalid records, which once threatened to bring pipelines to a halt, now land in a dedicated errors table for review. “If something goes wrong, we can still remain available for valid records, and we have an auditable trail for what didn’t make it,” he says.

Today, ClickPipes reliably moves more than 100 MB of events per second from WarpStream into ClickHouse Cloud, feeding a dataset of more than 300 TB of total data that’s growing by 40 TB each month. Instead of adding another system to build and maintain, it removes the ingestion burden while also removing the gray areas that used to slow them down. That clarity lets the team stay focused on building product features and spinning up new integrations quickly, knowing the underlying pipeline is solid.

“We’re helping thousands of mobile apps optimize subscription monetization in real time, and that demands a data streaming platform that’s fast, durable, and super low-maintenance,” says Brian. “WarpStream gives us Kafka compatibility with far less operational overhead—so we can easily stream and reprocess massive event volumes with confidence. Combined with ClickHouse Cloud, it’s a durable, scalable, and powerful data foundation that lets our small team move fast, maintain reliability, and keep innovating for our customers.”

Confluent + ClickHouse = “Durable, Scalable, Powerful”

Even at Superwall’s scale, customer dashboards still load in seconds. Developers get the immediate visibility they need to measure the success of pricing experiments or checkout flows without delay.

For Brian, the strength of the new stack lies in its balance of durability, scalability, and simplicity. Kafka compatibility ensures that no data is lost and makes it easy to reprocess streams when new use cases arise. ClickHouse’s materialized views and indexing strategies give the team the performance to support complex breakdowns (like analyzing paywall conversion rates across dozens of attributes) without trade-offs. And because the stack is fully managed, the team can focus on product innovation instead of operations.

Superwall’s data stack today, powered by WarpStream and ClickHouse Cloud

“It's totally elastic,” Brian says of the new stack. “We can increase our volume as much as we want, both on the storage side and the streaming side. And it's pretty much ops-free, which is the goal we were trying to get to.”

With Warpstream and ClickHouse Cloud, what was once a patchwork of managed services and constant disk resizing has become a cohesive architecture that connects streaming and analytics in a single, resilient pipeline. When asked to sum up the stack in three words, Brian pauses for a moment and says, “Durable, scalable, powerful.”

Helping Mobile Apps Monetize Smarter

Today, Superwall is starting to layer on new artificial intelligence (AI)-driven features such as Demand Score, which rolls countless signals into a single metric predicting a user’s likelihood to subscribe. It’s an early example of how the company plans to bring more intelligence and personalization to developers. “There’s a lot more we’ll be doing on top of Confluent and ClickHouse,” Brian says.

That solid foundation gives Superwall the freedom to focus on what matters: building product. “We wanted to make our systems as horizontally scalable, simple, and operationally non-intensive as possible,” Brian says. “Because for us to be successful, we don’t have to be 10x Kafka engineers or 10x ClickHouse engineers. We need to make a great product.”

Superwall’s ambitions are big, but the team remains grounded. “We’re a small team, and we do the best we can,” Brian says. “But we definitely rely on great vendors and partners.” With Confluent and ClickHouse working side by side, the team is ready to keep building, iterating, and helping mobile subscription apps optimize monetization.

Ready to take your data stack to the next level? Get started with a free trial of ClickHouse Cloud and WarpStream today.


Apache®, Apache Kafka®, and Kafka® are registered trademarks of the Apache Software Foundation. No endorsement by the Apache Software Foundation is implied by the use of these marks.

  • This blog was a collaborative effort between multiple Confluent employees.

  • This blog was a collaborative effort between multiple ClickHouse employees.

Did you like this blog post? Share it now