搜索结果:afk(7 个)
按分类缩小范围
flink-cdc
综合 67
基于 Apache Flink 的流式数据集成工具。
debezium
综合 65
面向多种常见数据库的分布式变更数据捕获(CDC)平台。
stream-reactor
综合 59
stream-reactor 是 Kafka Connect 连接器集合,解决 Kafka 与外部系统的数据同步问题。它提供多种 Source 和 Sink 连接器,支持 S3、Cassandra、MongoDB 等存储与队列,方便搭建实时数据管道。
alpakka-kafka
综合 55
Alpakka Kafka 是面向 Java 和 Scala 的 Kafka 连接器。它主要解决 Kafka 与响应式流(Reactive Streams)系统的集成问题,通过将 Apache Kafka 无缝接入 Akka Streams,提供原生支持背压(Backpressure)的流式数据处理能力。
fs2-kafka
综合 52
fs2-kafka 是一个基于 Scala 的开源库。它结合官方 Apache Kafka 客户端与 FS2 框架,解决在 Scala 函数式编程中以流式方式操作 Kafka 的问题。核心功能是提供纯函数式的 API,支持以流(Stream)的形式高效消费、生产和处理 Kafka 消息。
embedded-kafka
综合 48
〔中文简介暂未生成〕 A library that provides an in-memory Kafka instance to run your tests against.
zio-kafka
综合 42
〔中文简介暂未生成〕 A fast Kafka client for ZIO and ZIO Streams