linkedin / linkedin/kafka-tools
Kafka leader ordering
Nobody has claimed this yet.
- Dominant language
- Python
- Stars
- 599
- Forks
- 145
- PR merge metrics
- No merged PRs in 30d
Description
Hello , I am a little confused with kafka leader ship reordering.
if new_leader is None:
for replica in partition.replicas:
leader_ratio = leaders[replica.id] / replica.num_partitions() -> will this not be most of the times 0 hence it is not balanced. What is the logic behind this ?
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start by tracing the leader-reordering branch guarded by `new_leader is None`, especially the loop over `partition.replicas` and the `leaders[replica.id] / replica.num_partitions()` calculation. Determine whether the reported ratio is intentional and document or correct the behavior so the balancing logic and its expected result are clear.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- kafka, python
- Domain
- distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100