文件名称：decaton:Apache Kafka 上的高吞吐量异步任务处理
文件大小：741KB
文件格式：ZIP
更新时间：2024-08-24 17:02:16
java kafka kafka-consumer Java
迪卡顿 Decaton 是一个建立在之上的流式任务处理框架。 它旨在实现“从一个分区消费的记录的并发处理”，这在许多 Kafka 消费者框架中是不可能的。 以下是 Decaton 默认启用的属性列表： 从一个分区消耗的记录的并发（多线程或异步）处理 通过记录键保留排序保证 无论记录以何种顺序处理，都保留至少一次交付语义 Decaton 是一个库，而不是一个全栈执行环境，因此您只需添加几行工件依赖项，就可以轻松地将它集成到您现有的/新的 JVM 应用程序中。 由于它已经设计、优化并用于的服务器系统，每个流每秒产生超过 100 万个 I/O 密集型任务，其内部实现记录并发处理的实现高度优化，可以产生理想的吞吐量以最少的服务器数量，最大限度地提高资源利用率。 入门/教程 请参阅 何时使用（何时不使用） 当您的处理逻辑包含针对外部系统的 I/O 访问（例如，DB 访问、Web API