Karafka v2.3.2 发布，基于 Apache Kafka 的应用程序开发框架

Karafka v2.3.2 现已发布。Krafka 是一个用于简化基于 Apache Kafka 的 Ruby 应用开发的框架，它允许开发者在使用异步 Kafka 消息时使用类似于标准 HTTP 约定（params 和 params_batch）的方法。Karafka 不仅可以处理传入的消息，而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。

此版本更新内容如下：

• [功能] 为OSS和Pro提供swarm能力。
• [功能] 提供在 DLQ (Pro) 中使用复杂策略的能力。
• [增强] 支持使用:partition用作 ActiveJob assignments 的分区键。
• [增强] 使用群通知扩展 Logger 监听器。
• [增强] 引入 K8s swarm liveness 监听器。
• [增强] 在 Ruby 3.3+ 中，在分叉（在 swarm 中）之前和应用程序启动之前使用Process.warmup。
• [增强] 提供app.before_warmup事件以允许在最终预热之前挂载代码加载工具。
• [增强] 提供Consumer#errors_tracker以获取在进行复杂恢复时发生的错误。
• [修复] 使用 VP 且不使用 DLQ 的无限连续错误流可能会导致无限的偏移累积。
• [修复] Quieting 模式会导致过早 unsubscribe。

更新说明：https://github.com/karafka/karafka/releases/tag/v2.3.2