opensource4you / astraea

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

[COMMON] Replace NodeInfo with Broker #1763

Closed chaohengstudent closed 1 year ago

chaohengstudent commented 1 year ago

related to #1721

主要改動

NodeInfo 移除,改由 Broker 物件取代

NodeInfo.of(int id, String host, int port) -> Broker.of(int id, String host, int port) NodeInfo.of(org.apache.kafka.common.Node node) -> Broker.of(org.apache.kafka.common.Node node)

這兩個建構方法會導致其他資訊為空值(目前 Admin.partitions 和 Admin.replicas 中使用到的 Broker ),不知道是否合理還是需要確保資訊的完整

修改 Broker

相關改動

Admin.nodeInfos() -> Admin.brokers() Replica.nodeInfo() -> Replica.broker()

TODO

若此 pr 可以合併將在 #1721 完成下述: 修改 toBytes(ClusterInfo value) 修改 readClusterInfo(byte[] bytes) 因序列化格式須修改,測試先暫時移除

chia7712 commented 1 year ago

Broker.of(org.apache.kafka.common.Node node)

請問一下這個方法的用途?如果是從Admin來建立的話應該是可以建立完整的資訊?

chaohengstudent commented 1 year ago

請問一下這個方法的用途?如果是從Admin來建立的話應該是可以建立完整的資訊?

目前情境是當 Broker 離線時會沒有辦法拿到其他資訊

chia7712 commented 1 year ago

麻煩修正一下衝突,以及標題名稱修改一下

chia7712 commented 1 year ago

標題名稱要加讓 [COMMON]