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


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

此版本更新内容如下:

  • [Feature] 提供将 CurrentAttributes 与 ActiveJob 的 Karafka 适配器一起使用的能力。
  • [Feature] 引入集体虚拟分区偏移量管理。
  • [Feature] 使用虚拟偏移量过滤掉重试时会重新处理的消息。
  • [Improvement] 不再中断 ActiveJob 中失败的并行虚拟分区的处理,因为它由虚拟标记补偿。
  • [Improvement] 始终对 Pro ActiveJobs 使用虚拟偏移管理。
  • [Improvement] 不要尝试在已撤销的分区上标记偏移量。
  • [Improvement] 确保 VP 组件不会注入到非 VP 策略中。
  • [Improvement] 改进复杂的策略继承流程。
  • [Improvement] 优化 DLQ + MoM feature 组合的偏移量管理。
  • [Change] 删除Karafka::Pro::BaseConsumer以支持Karafka::BaseConsumer。(#1345)
  • [Fix] 修复max_messagesmax_wait_time在 errors.yml 中没有引用的问题(#1443)

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


相关文章

2022-08-24

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

2022-09-04

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

2022-07-10

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

2023-07-01

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

2023-06-21

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

2022-12-22

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

2023-01-12

息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。 此版本更新内容如下: [Feature] 允许通过设置active为 false 来禁用给定的主题。它会将它们排除在 consumption 之外,但会允许它们定义使用管理 API

2022-05-24

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

2022-04-19

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

2023-06-07

v2.1.0 更新内容: 1、新增依赖文件 requirements.txt 文件; 2、修复近期用户反馈的问题; 一款 Python 语言基于 Flask、Vue2.x、ElementUI、MySQL 等框架精心打造的一款模块化、高性能、企业级的敏捷开发框架,本着简化开发、提升开发效

2022-05-17

是在 Aiven 社区内采取集体行动,在云中构建更可持续的应用程序。 继去年建立一个正式的开源项目办公室和启动 Cluster 项目之后,该公司致力于进一步普及最佳数据技术,减少云服务对环境的影响,并在 Aiven 和更广泛的科技

2023-09-15

本着重支持 Apache Seatunnel 作为流水线支持框架 DataCap 已发布 发布版本 发布时间 1.14.0 2023-09-14 General 修复数据源检查任务返回空的问题 添加验证码 支持登录验证码 支持验证码失败自动刷新 支

2022-09-29

Apache Flink 1.14.6 现已发布,这是一个错误修复版本。包括针对 Flink 1.14 的 34 个错误修复、漏洞修复和小改进。有关所有更改的完整列表可参阅:JIRA。官方强烈建议所有用户升级到 Flink 1.14.6。 具体更新内容包括: Bug [FLINK-248

2022-09-05

与统一维护管理的模块。 通知公告:系统通知公告信息发布维护。 代码生成:一键生成模块 CRUD 的功能,包括后端和前端 Vue 等相关代码。 案例演示:常规代码生成器一键生成后的演示案例。 软件信息 软件名称:RXTh