复杂的流处理变得操作上平凡。此仓库是原始项目在许可证更改前的分支。
[![godoc for warpstreamlabs/bento][godoc-badge]][godoc-url] [![构建状态][actions-badge]][actions-url] [![govulncheck][govulncheck-badge]][govulncheck-url] [![Docs 网站][website-badge]][website-url] Bento 是一款高性能且具备弹性的流处理器,能够在多种中介模式下连接各种 [源][输入] 和 [汇出][输出],并对负载执行 [加水、增强、转换和过滤][处理]。 它配备了强大的映射语言 [bloblang-about],易于部署和监控,可以作为静态二进制文件、Docker 映像或 [无服务器函数][serverless] 直接插入到您的工作流中,使其具备云原生特性。 交付保证 [可能是一个不靠谱的主题](https://youtu.be/QmpBOCvY8mY)。Bento 使用一个进程内事务模型来处理和确认消息，无需任何持久化到磁盘的状态，因此在连接到至少一次源和汇的情况下，即使在发生崩溃、磁盘损坏或其他意外的服务器故障情况下，也能保证至少一次的交付。这种行为是默认的，不存在任何警告，这也使得部署和扩展 Bento 变得更加简单。 AWS (DynamoDB、Kinesis、S3、SQS、SNS)、Azure (Blob 存储、队列存储、表存储)、GCP (Pub/Sub、云存储、大型查询)、Kafka、NATS (JetStream、流式传输)、NSQ、MQTT、AMQP 0.91 (RabbitMQ)、AMQP 1、Redis (流、列表、Pub/Sub、哈希)、Cassandra、Elasticsearch、HDFS、HTTP（服务器和客户端，包括 WebSocket）、Mo [Discord](https://console.warpstream.com/socials/discord) [Slack](https://console.warpstream.com/socials/slack)
暂无开放 Issues，或尚未同步最近议题。