Cloudflare推出K2事件流服务，基于R2对象存储绕开Kafka

Cloudflare近日推出无服务器事件流服务K2的公测版。该服务底层是在R2对象存储中运行的分区持久化日志，通过以延迟换取成本优势和弹性扩展，为边缘计算场景提供新的消息管道方案。Cloudflare公布的数据显示，生产端延迟的p99约为一秒，但公开测试中端到端交付速度比这一数字更慢。

K2最初只是作为底层管道开发。Cloudflare的Basin Pipelines需要一个持久化位置来暂存事件，等待基于拉取模式的处理引擎读取并转换。多数公司遇到此类需求会选择Apache Kafka，但Pipelines运行在覆盖335个以上城市的边缘网络中，使用临时机器上的少量计算资源，通过公共互联网连接，Kafka的设计并未考虑这些条件。因此Cloudflare选择以R2为底座，其提供十一个9的持久性与强一致性API，将复制和共识机制下沉至存储层后，计算与存储可独立扩展。

对象存储无法追加写入，而日志依赖追加操作。K2的解决办法是先在边缘服务内存中暂存写入，短暂停顿等待更多数据到达，再将整批数据写成一个分段文件，由R2的原子操作保证顺序并生成递增偏移量，因此无需协调服务，这段等待时间正是延迟来源。

Hacker News上的讨论总体认可这一架构模式，但对性能数据提出质疑。一名公测用户报告写入延迟低于一秒，端到端交付延迟却达到p95 2.5秒、p99 7.5秒。代表团队回应的评论者承认长尾延迟高于预期，Consume API性能仍需改进，读取延迟优化预计约一周内显现。定价方面，每生产1GB数据收费0.04美元，消费数据收取相同费用，有评论者认为单消费者场景实际成本为0.08美元/GB，扇出式消费者策略下成本会迅速升高，而扇出正是Cloudflare为K2定位的应用场景之一。数据保留费用为每月每GB 0.02美元，公测期间不收费。