-
Notifications
You must be signed in to change notification settings - Fork 62
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Score on partition #303
Score on partition #303
Conversation
這裡新增介面, 包含4種建立方法,
|
Move `leaderOf` to PartitionInfo and rename. Remove unused method.
@chia7712 可以麻煩您再review一次PR嘛?感謝您。 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@chinghongfang 感謝這個patch,看起來很棒
有幾個小建議請看一下
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
我覺得很棒,可以前進了。
如#289 (comment)
需要對partition進行打分。更甚者,包括replica也要打分。
更改CostFunction的回傳值,CostFunction將會對
org.apache.kafka.common.TopicPartitionReplica
做打分。原本有許多cost function都是以broker進行打分的,目前我不做更動,只有讓它們符合現在的介面,本質仍然是對broker打分,以後也許可以做更精準的打分(對partition打分)。
另外,在進行修改的過程中發現,partitioner 會希望 cost function 知道發送到哪個 topic,之後要討論"新增topic 到cost function 參數中"。