Karafka v2.0.0.alpha6 发布
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 时分配回来...