Karafka v2.5.7 发布,基于 Apache Kafka 的应用程序开发框架
Karafka v2.5.7 现已发布。Krafka 是一个用于简化基于 Apache Kafka 的 Ruby 应用开发的框架,它允许开发者在使用异步 Kafka 消息时使用类似于标准 HTTP 约定(params 和 params_batch)的方法。Karafka 不仅可以处理传入的消息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [Enhancement] 强制关闭期间,报告详细的阻塞信息(活动监听器、存活工作进程和正在处理的作业),而不仅仅是汇总计数。 [Enhancement] 改进ForcefulShutdownError描述,以清晰说明何时以及为何会触发该异常。 [Enhancement] 在BatchMetadata构建器中添加messages.last缓存,以避免重复遍历数组。 [Enhancement] 优化VirtualOffsetManager#mark,使用单次数组扫描代替单独的include?和index调用(Pro)。 [Enhancement] 优化VirtualOffsetManager#materializ...
