导读 Karafka v2.1.7 现已发布。Krafka 是一个用于简化基于 Apache Kafka 的 Ruby 应用开发的框架,它允许开发者在使用异步 Kafka 消息时使用类似于标准 HTTP 约定(params 和 params_batch)的方法。

Karafka 不仅可以处理传入的消息,而且还提供了用于构建接收和发送消息的复杂数据流应用程序的工具。

此版本更新内容如下:
  • [[Improvement] 始终在迭代器中查询水印,以提高初始响应时间。
  • [[Improvement] 为迭代器添加 max_wait_time 选项。
  • [Fix] 修复了 Admin#read_topic 在不存在的消息上等待轮询间隔而不是提前退出的情况。
  • [Fix] 在迭代器中,如果每个分区的偏移量为负数,则迭代器的查找次数会低于可用消息的数量。
  • [Fix] 从管理模块中删除未使用的常量。
  • [Fix] 在 LoggerListener 仪器 hook 中添加缺失的 connection.client.rebalance_callback.error。
  • 更新说明://github.com/karafka/karafka/releases/tag/v2.1.7

    原文来自:

    本文地址://gulass.cn/karafka-apache-linux.html编辑:向云艳,审核员:清蒸github

    Linux大全:

    Linux系统大全:

    红帽认证RHCE考试心得: