Karafka v2.1.0 现已发布。Krafka 是一个用于简化基于 Apache Kafka 的 Ruby 应用开发的框架，它允许开发者在使用异步 Kafka 消息时使用类似于标准 HTTP 约定（params 和 params_batch）的方法。Karafka 不仅可以处理传入的消息，而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。
此版本更新内容如下：
- [Feature] 提供将 CurrentAttributes 与 ActiveJob 的 Karafka 适配器一起使用的能力。
- [Feature] 引入集体虚拟分区偏移量管理。
- [Feature] 使用虚拟偏移量过滤掉重试时会重新处理的消息。
- [Improvement] 不再中断 ActiveJob 中失败的并行虚拟分区的处理，因为它由虚拟标记补偿。
- [Improvement] 始终对 Pro ActiveJobs 使用虚拟偏移管理。
- [Improvement] 不要尝试在已撤销的分区上标记偏移量。
- [Improvement] 确保 VP 组件不会注入到非 VP 策略中。
- [Improvement] 改进复杂的策略继承流程。
- [Improvement] 优化 DLQ + MoM feature 组合的偏移量管理。
- [Change] 删除
Karafka::Pro::BaseConsumer以支持Karafka::BaseConsumer。（#1345） - [Fix] 修复
max_messages和max_wait_time在 errors.yml 中没有引用的问题（#1443）
更新说明：https://github.com/karafka/karafka/releases/tag/v2.1.0