[KAFKA-13226] Partition expansion may cause uneven distribution - ASF JIRA

XML

Word

Printable

JSON

Flags:

Patch, Important
External issue URL:
https://shirenchuang.blog.csdn.net/article/details/119912418
Language:
- scala

Partition expansion may cause uneven distribution

1. Create a Topic , 3-partition 1-replical

2. partition expansion to 5 - partiton

3. Does this meet expectations ？

so this is a bug ?

The problem may arise here ;

When we create a new topic . get the broker list is a Object Map ;

This is disordered

you can read the code , first it have sortBy brokerId, but finally it convert to a disorde Map;

The important thing is that it has been sorted when expanding the partition and parition-reassignment ;

So why not sort when creating topics?

If the topic is sorted when create a new topic , this problem will not occur ;

so it maybe is a tiny bug ?

if you can read Chinese ,

You can look at this article. I describe it in detail

We look forward to receiving your reply

如果你能看懂中文,可以看看这篇文章我描述的很详细!