搜索结果：streaming（7 个）

基于 Apache Flink 的流式数据集成工具。

面向多种常见数据库的分布式变更数据捕获（CDC）平台。

Apache Pekko 是基于 Actor 模型的开源框架（源自 Akka 2.6.x 分支），旨在解决 Java/Scala 开发者构建高并发、分布式及弹性消息驱动应用的复杂难题。其核心通过高级并发抽象，提供持久化、流处理（Streams）和 HTTP 等配套库，支持构建高可用的分布式系统。

redis4cats 是一个 Scala 版的 Redis 客户端，基于 Cats Effect、Fs2 和 Java 异步客户端 Lettuce 构建。它解决了在函数式编程中安全、异步操作 Redis 的需求，提供纯函数式的 Effects API 与 Streams 流式处理支持，适用于生产环境。

Ox 是面向 Scala 3 和 JDK 21+ 的并发与流处理库。它基于 JVM 虚拟线程，让开发者无需复杂的异步语法，就能以直观的“直接风格”编写高并发代码。核心功能包括结构化并发（安全管理生命周期与异常）、带背压的流处理，以及熔断、重试、限流等容错韧性机制。

〔中文简介暂未生成〕 Lightweight real-time big data streaming engine over Apache Pekko

FS2 是 Scala 的纯函数式流式 I/O 处理库，主要解决高并发、带副作用数据流的安全与高效处理问题。其核心提供可组合的流（Stream）和拉取（Pull）抽象，在保障资源安全与高性能的同时，支持与 Cats-Effect 等不同副作用库结合使用。