Karafka v2.5.4 已正式上线。Karafka 是一款专为 Ruby 开发者打造的高效框架,旨在降低基于 Apache Kafka 构建应用的复杂度。它支持以类 HTTP 的方式处理异步 Kafka 消息(例如通过 params 和 params_batch),不仅可轻松消费消息,还内置了构建高可用、可扩展的消息收发与数据流系统的完整工具链。
本次版本主要更新如下:
UnsupportedCaseError 替换为统一的通用错误日志记录方式,确保其行为与主日志监听器一致,从而提升动态错误上报能力。USER_CONSUMER_ERROR_TYPES 配置,使其覆盖全部 consumer 错误类型,实现端到端的错误追踪闭环。Messages#each 方法用于内部遍历逻辑,避免依赖被外部库(如 DataDog 追踪模块)劫持或补丁
化的枚举方法,解决与 Messages#raw 前置模块加载场景下的兼容性异常。base64 标准库的显式依赖(Ruby 内置,无需额外引入)。ErrorTypesChecker 规范支持模块,支持自动化校验各监听器所声明的错误类型是否与源码中实际定义的错误集合完全匹配。更新详情请参阅:https://www./link/ce69714025385b379247c4d0e0444606
源码地址:点击下载