Karafka v2.0.26 发布,基于 Apache Kafka 的应用程序开发框架


Karafka v2.0.26 现已发布。Krafka 是一个用于简化基于 Apache Kafka 的 Ruby 应用开发的框架,它允许开发者在使用异步 Kafka 消息时使用类似于标准 HTTP 约定(params 和 params_batch)的方法。Karafka 不仅可以处理传入的消息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。

此版本更新内容如下:

  • [Feature] 允许通过设置active为 false 来禁用给定的主题。它会将它们排除在 consumption 之外,但会允许它们定义使用管理 API 等。
  • [Improvement] 当达到请求时间的最后一个可用偏移量时提前终止read_topic的运行。
  • [Improvement] 引入一种quiet状态,表明 Karafka 不仅正在转向 quiet 模式,而且实际上已经达到 quiet 模式,并且在任何 consumer groups 中都不会再发生任何工作。
  • [Improvement] 尽可能使用 Karafka 定义的 routes topics,用于read_topic管理 API。
  • [Improvement] 引入client.pauseclient.resumeinstrumentation hooks,用于跟踪客户端主题分区暂停和恢复。除此之外,它还可以与consumer.consuming.pause一起,用来跟踪手动和自动暂停,并提供更细化的 consumer 相关细节。client.*应该被用于 low level tracking。
  • [Improvement] 将LoggerListener暂停通知替换为一个基于client.pause而不是consumer.consuming.pause的通知。
  • [Improvement] 扩展LoggerListenerclient.resume通知。
  • [Improvement] 用稳定的一次匿名订阅组 ID 替换随机的匿名订阅组。
  • [Improvement] 添加consumer.consume,consumer.revokeconsumer.shutting_down通知事件,并将撤销逻辑调用移至策略。
  • [Change] 将作业队列统计processing键重命名为busy。无需更改,因为 DataDog 监听器中的命名保持不变。
  • [Fix] 修复 proctitle 监听器状态更改报告新状态。
  • [Fix] 确保所有 files descriptors 在集成规范中都已关闭。
  • [Fix] 修复空订阅组可能会泄漏到执行流程中的情况。
  • [Fix] 修复LoggerListener报告,使其不以.结束。
  • [Fix] 运行在 Karafka 信号陷阱之前创建的先前定义的(如果有的话)信号陷阱。

更新说明:https://github.com/karafka/karafka/releases/tag/v2.0.26 

 


相關推薦

2022-08-24

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 目前 Karafka v2.0.5 发布了,此版本更新内容如下: 修复 Ruby on Rails 的 karafka.rb 模板中不必要的双换行符 修复手动暂停的分区在重新平衡后不会被处

2022-09-04

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: 改善 client closing。 修复:多个 LRJ 主题同时获取会阻碍 LRJ 启动的能力(#1002) 引入 pre-enqueue 同步执行层以防止 LRJ 出现&n

2023-07-01

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [改进] 为迭代器提供时间支持 [改进] 为admin #read_topic提供时间支持 [改进] 为consumer #see提供时间支持。 [改进] 删除客

2022-07-10

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: 从侦听器内联代码中提取消费分区器。 引入虚拟分区器概念,用于并行处理来自单个主题分区的数据。 在轮询时发生 kafk

2023-05-24

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [Feature] 提供将 CurrentAttributes 与 ActiveJob 的 Karafka 适配器一起使用的能力。 [Feature] 引入集体虚拟分区偏移量管理。

2023-06-21

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [Improvement] 通过检查 librdkafka 上的实时分配丢失状态,来显着提高#revoked?响应质量。 [Improvement] 改进将在已撤销的分

2022-12-22

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [Feature]为 Pro 提供开箱即用的加密支持。 [改进] 在#pause上添加检测。 [改进] 在重试时添加检测。 [改进] 分配#id给类似于

2024-02-28

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [增强] 基于路由的 Swarm 主题分配 (Pro) [增强] 发布 swarm 中无响应节点的-1关闭原因状态。 [增强] 允许在 DataDog 监听器直方

2023-10-22

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [功能] 引入 Appsignal 集成,用于 errors 和 metrics 跟踪。 [改进] 为 VP 提供#synchronize,以便在需要跨 VP consumers 工作时允许

2024-02-21

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [功能] 为OSS和Pro提供swarm能力。 [功能] 提供在 DLQ (Pro) 中使用复杂策略的能力。 [增强] 支持使用:partition用作 ActiveJ

2023-08-22

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [增强功能] 引入 connection.client.rebalance_callback 事件,用于再平衡的工具化。 [重构] 引入低级命令代理来处理希望如

2022-05-24

Karafka 2.0 Beta 发布,更新内容如下: 更新作业队列的阻塞引擎,允许非阻塞作业的执行 提供 #prepared hook,总是在获取循环未阻塞之前运行。 [Pro] 为调度优化器引入性能跟踪器 提供暂停(#pause)和恢复(#resume)消费者给

2022-04-19

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容: 修复了一个 BUG,在缺少启动文件和 Rails 时,railtie 出现 generic exception 而失败(#818) 修复了在捆绑安装过程中,并行原始规范

2024-02-15

5,300+ 拉取请求 2,300+ 问题 230+ 贡献者 131 个发布版本 15 个公开生产用户 2800+位于#strimzi CNCF Slack 频道的用户 由于使 Apache Kafka 在 Kubernetes 上以“云原生”方式运行的能力,Strimzi 与其他 CNCF 项目集成,包括 Pr