Karafka v2.5.4 已正式上线。Karafka 是一款专为 Ruby 开发者打造的高效框架，旨在降低基于 Apache Kafka 构建应用的复杂度。它支持以类 HTTP 的方式处理异步 Kafka 消息（例如通过 params 和 params_batch），不仅可轻松消费消息，还内置了构建高可用、可扩展的消息收发与数据流系统的完整工具链。

本次版本主要更新如下：

• 【功能增强】完善 Datadog 日志监听器的错误处理机制：补充缺失的错误类型，并将 UnsupportedCaseError 替换为统一的通用错误日志记录方式，确保其行为与主日志监听器一致，从而提升动态错误上报能力。
• 【功能增强】同步 Appsignal metrics 监听器中的 USER_CONSUMER_ERROR_TYPES 配置，使其覆盖全部 consumer 错误类型，实现端到端的错误追踪闭环。
• 【功能增强】优化 gem 构建流程，移除 spec、示例代码、CI 配置及开发脚本等非运行时文件，显著缩减最终 gem 包体积。
• 【问题修复】修复了多次调用路由定义（Multiple route draws）时未能正确生效的问题。
• 【问题修复】新增 Messages#each 方法用于内部遍历逻辑，避免依赖被外部库（如 DataDog 追踪模块）劫持或补丁化的枚举方法，解决与 Messages#raw 前置模块加载场景下的兼容性异常。
• 【维护升级】移除对 base64 标准库的显式依赖（Ruby 内置，无需额外引入）。
• 【维护升级】新增 ErrorTypesChecker 规范支持模块，支持自动化校验各监听器所声明的错误类型是否与源码中实际定义的错误集合完全匹配。

更新详情请参阅：https://www./link/ce69714025385b379247c4d0e0444606

源码地址：点击下载