Karafka v2.1.5 现已发布。Krafka 是一个用于简化基于 Apache Kafka 的 Ruby 应用开发的框架，它允许开发者在使用异步 Kafka 消息时使用类似于标准 HTTP 约定（params 和 params_batch）的方法。Karafka 不仅可以处理传入的消息，而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。
此版本更新内容如下：
- [Improvement] 通过检查 librdkafka 上的实时分配丢失状态，来显着提高
#revoked?响应质量。 - [Improvement] 改进将在已撤销的分配上运行的饱和作业的驱逐。
- [Improvement] 在 consumer 中 Expose
#commit_offsets和#commit_offsets!方法，以提供直接向 Kafka 提交偏移量的能力，而无需将新消息标记为 consumed。 - [Improvement] 当没有消息标记为 consumed 时不再跳过偏移量提交，因为
librdkafka已修复那里的崩溃。 - [Improvement] 删除不再需要的补丁。
- [Improvement] 确保在使用
#revoked?时，协调器撤销状态在撤销检测时切换 - [Improvement] 添加标记为 consumed 的基准（同步和异步）。
- [Change] 要求
karafka-core>= 2.1.0 - [Change] 要求
waterdrop>= 2.6.1
更新说明：https://github.com/karafka/karafka/releases/tag/v2.1.5