Karafka v2.2.8 現已發布。Krafka 是一個用于簡化基于 Apache Kafka 的 Ruby 應用開發的框架,它允許開發者在使用異步 Kafka 消息時使用類似于標準 HTTP 約定(params 和 params_batch)的方法。Karafka 不僅可以處理傳入的消息,而且還提供了用于構建接收和發送消息的復雜數據流應用程序的工具。
此版本更新內容如下:
- [功能] 引入 Appsignal 集成,用于 errors 和 metrics 跟蹤。
- [改進] 為 VP 提供
#synchronize
,以便在需要跨 VP consumers 工作時允許鎖定。 - [改進] 提供
#collapse_until!
direct consumer API,以便在高級用例中結合過濾 API 進行折疊虛擬分區消費者操作。 - [重構] 重組再平衡事件從 librdkafka 傳播到 Karafka 的方式。用 rebalance.partitions_assigned 和 rebalance.partitions_revoked 替換 connection.client.rebalance_callback。引入兩個額外事件:rebalance.partitions_assign 和 rebalance.partitions_revoke,以處理未來的預平衡工作。
- [重構] 刪除作為 CLI 層的
thor
,轉而依賴 RubyOptParser
Upgrade notes
- 除非你使用的
connection.client.rebalance_callback
是被認為是私有的,否則什么都沒有。 - 所有 CLI 命令都不會有任何變化,但
thor
已被刪除,因此如果發現任何錯誤,建議報告。