search

opensource4you / astraea

釋放kafka的無限潛能
Apache License 2.0
129 stars 46 forks source link

[TEST] Fix flaky BackupTest#testRestoreDistribution() #1785

Closed chaohengstudent closed 1 year ago

chaohengstudent commented 1 year ago

fix #1784 在 SERVICE 中獲取到的 controller id 是隨機的 (case KRaftCachedControllerId(_) => metadataCache.getRandomAliveBrokerId)， 所以會導致replica 在重新建構後所在的同一個Broker.isController 不一致 目前改成只透過 replica 及 leader 的 topic partition 對應的 broker id 判斷分佈是否一致