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

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

此版本更新内容如下：

• [增强功能] 引入 connection.client.rebalance_callback 事件，用于再平衡的工具化。
• [重构] 引入低级命令代理来处理希望如何运行某些命令以及 rdkafka-ruby 如何按设计运行该命令的偏差。
• [修复] 当分配不可行的情况下，不要在 DD listener 中报告延迟。
• [修复] 不要在 DD listener 中报告负滞后。
• [修复] 规格中启动后极快关闭可能会导致进程不停止。
• [修复] 默认情况下禁用管理员的allow.auto.create.topics权限，以防止在主题元数据查找时意外创建主题。
• [修复] 通过增加过低的超时来改进query_watermark_offsets操作。
• [修复] 增加TplBuilder超时以补偿远程集群。
• [修复] 始终尝试取消订阅整个系统中使用的 short-lived consumers，尤其是在管理 API 中。
• [修复] 添加缺失的connection.client.poll.error错误类型引用。

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