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

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

此版本更新内容如下：

• [改进] 为迭代器提供时间支持
• [改进] 为admin #read_topic提供时间支持
• [改进] 为consumer #see提供时间支持。
• [改进] 删除客户端操作不再需要的锁。
• [改进]尝试迭代不存在的主题时引发Karafka::Errors::TopicNotFoundError。
• [改进] 确保 Kafka 多命令操作在 mutex 下一起运行。
• [更改] 要求waterdrop >= 2.6.2
• [更改] 要求karafka-core >= 2.1.1
• [重构] 清理迭代器代码。
• [修复] 提高 Rails 应用程序开发环境中的性能 (juike)
• [修复] 重命名InvalidRealOffsetUsage为InvalidRealOffsetUsageError以与其他 errors 的命名保持一致。
• [修复] 修复不稳定的规范。
• [修复] 修复运行 LRJ 时自动#seek会覆盖用户手动搜索的情况。
• [修复] 确保用户直接的#seek和#pause操作优先于系统操作。
• [修复] 确保#pause和#resume在一个底层连接不会出现 race-condition。

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