Skip to content

Commit a9fbfec

Browse files
stop flaky test failures (#159)
* add sleep to stop flaky test failures * remove unused import * fix sleep * fix retry instead of sleeping * improve checks * remove duplicate code * use one retry
1 parent 410aed6 commit a9fbfec

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

pkg/admin/brokerclient_test.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -455,10 +455,18 @@ func TestBrokerClientAlterAssignments(t *testing.T) {
455455
topicInfo, err = client.GetTopic(ctx, topicName, true)
456456
require.NoError(t, err)
457457

458+
// Alter partition succeeded
458459
if topicInfo.Partitions[2].Replicas[0] != 5 {
459460
return fmt.Errorf("Assign partitions change not reflected yet")
460461
}
461462

463+
// ISR shrink completed
464+
for _, partition := range topicInfo.Partitions {
465+
if len(partition.Replicas) != 2 {
466+
return fmt.Errorf("Assign partitions change not reflected yet")
467+
}
468+
}
469+
462470
return nil
463471
})
464472

0 commit comments

Comments
 (0)