opensource4you / astraea

釋放kafka的無限潛能
Apache License 2.0
125 stars 45 forks source link

[METRICS] Implementation of fixed receiver #1795

Closed garyparrot closed 1 year ago

garyparrot commented 1 year ago

Resolve #1710

這個 PR 實作一個新的 Metric Store receiver Receiver#fixed(Map<Integer, Collection<BeanObject>)

這個 Receiver 只會在第一次呼叫 receive 時回傳建立時提供的 Beans,然後就不再回傳任何新的 Beans。後面這個會和 #1769 的序列化功能搭配,從檔案系統將 BeanObjects 還原回 Map<Integer, Collection<BeanObject>,然後把這個東西當做輸入給 Receiver 的輸出使用,而後從 MetricStore#clusterBean 取得最後的 ClusterBean 物件。

這個大致上是後面 benchmark 的 ClusterBean 還原方法。