[kafka] branch 2.8 updated: HOTFIX: fix cherry-pick to 2.8

[cm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cmccabe pushed a commit to branch 2.8
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.8 by this push:
     new f0e46f7  HOTFIX: fix cherry-pick to 2.8
f0e46f7 is described below

commit f0e46f7ad3007510c9f608314d7dbe9dab673a6e
Author: Colin P. Mccabe <cm...@confluent.io>
AuthorDate: Fri Feb 19 18:04:07 2021 -0800

    HOTFIX: fix cherry-pick to 2.8
---
 .../java/org/apache/kafka/controller/ReplicationControlManager.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
index aa60f51..ccf83bb 100644
--- a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
+++ b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
@@ -759,7 +759,7 @@ public class ReplicationControlManager {
             ReplicaElectionResult topicResults =
                 new ReplicaElectionResult().setTopic(topic.topic());
             response.replicaElectionResults().add(topicResults);
-            for (int partitionId : topic.partitions()) {
+            for (int partitionId : topic.partitionId()) {
                 ApiError error = electLeader(topic.topic(), partitionId, unclean, records);
                 topicResults.partitionResult().add(new PartitionResult().
                     setPartitionId(partitionId).