Using Apache Kafka to process 1 trillion inter-service messages
Jul 19, 2022Matt Boyle

Summary
This post details Cloudflare's extensive adoption and internal tooling development around Apache Kafka for inter-service communication. It highlights the use of Kafka to process over a trillion messages, the creation of internal tools like Messagebus-Client and a connector framework for easier adoption, the implementation of strict schemas using Protobuf for forward/backward compatibility, and the establishment of robust observability through automated metrics and alerts. It also provides a practical example of how this framework supports the Alert Notification System.
More from the Data Infrastructure & Analytics trail
- Introducing Cloudflare Basin: an open, serverless data platform, now generally available
- Introducing the Billable Usage API: programmatic cost visibility for Cloudflare
- Announcing the Monetization Gateway: charge for any resource behind Cloudflare via x402
- How we built Cloudflare's data platform and an AI agent on top of it
- Iran's Internet is partially restored, Cloudflare Radar data shows