Karafka v2.0.0.alpha6 现已发布。Krafka 是一个用于简化基于 Apache Kafka 的 Ruby 应用开发的框架,它允许开发者在使用异步 Kafka 消息时使用类似于标准 HTTP 约定(params 和 params_batch)的方法。Karafka 不仅可以处理传入的消息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。
此版本更新内容:
- 修复了一个 BUG,在缺少启动文件和 Rails 时,railtie 出现 generic exception 而失败(#818)
- 修复了在捆绑安装过程中,并行原始规范相互冲突的问题 (#820)
- 替换
consumer.consume
为consumer.consumed
事件,以符合行为规范 - 确保 offset committing 发生在
consumer.consumed
事件传播之前 - 修复未安装时失败的问题(只是一个依赖项)(#817)
- 从 rebalancing 时丢失的分区中 evict messages(#825)
- 不要在失去的分区上运行
#revoked
,并在 rebalancing 时分配回来(#825) - 移除重新分配的分区在重新平衡时可能出现的重复(#825)
- 优化集成测试套件额外消费者关闭过程(#828)
- 优化消息驱逐和因缺乏消息而停止的轮询时的重复删除
- 添加静态组成员身份集成规范
更新说明:https://github.com/karafka/karafka/releases/tag/v2.0.0.alpha6