Numaflow是一个基于Kubernetes的开源流处理引擎，旨在简化数据处理管道的构建，支持Kafka、Pulsar和SQS，适合高吞吐量工作负载。它隐藏基础设施细节，使机器学习工程师专注于流处理逻辑，并能自动扩展以应对流量变化。