mirror of
https://github.com/apache/kafka.git
synced 2026-10-28 08:24:58 +08:00
In `KRaftMetadataCache`, `getPartitionLeaderEndpoint` returns empty when the previous leader is offline after the refactor. With this PR, the method now returns `noNode` when the leader partition exists, aligning with the original Scala implementation. Changes are covered by unit tests. Please feel free to review. Reviewers: Kevin Wu <kwu@confluent.io>, Justine Olshan <jolshan@confluent.io>