Murali Basani ccf5ec3721 KAFKA-21376 Replace AdminUtils leader lookups with AdminClientTestUtils#currentLeader (#23990) ...

Add AdminClientTestUtils#currentLeader, which returns the current leader
of a partition without waiting. Remove AdminUtils#fetchOrWaitForLeader
and ClusterInstance#getLeaderBrokerId, and migrate all callers. Tests
that need a specific leader now wrap it in TestUtils#waitForCondition,
which also fixes the stale-leader race in LeaderElectionCommandTest.

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>

2026-11-04 03:02:32 +08:00

..

api/src

…

src

KAFKA-21376 Replace AdminUtils leader lookups with AdminClientTestUtils#currentLeader (#23990)

2026-11-04 03:02:32 +08:00