From e022160b29ac1ce54c8e0d5d1bd5aae679083654 Mon Sep 17 00:00:00 2001 From: Dong Lin Date: Fri, 22 Aug 2014 13:03:51 -0700 Subject: [PATCH] KAFKA-1609; New producer metadata response handling should only exclude a PartitionInfo when its error is LEADER_NOT_AVAILABLE --- .../main/java/org/apache/kafka/common/requests/MetadataResponse.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java b/clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java index 7d90fce..968185b 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java @@ -118,7 +118,7 @@ public class MetadataResponse extends AbstractRequestResponse { for (int j = 0; j < partitionInfos.length; j++) { Struct partitionInfo = (Struct) partitionInfos[j]; short partError = partitionInfo.getShort(PARTITION_ERROR_CODE_KEY_NAME); - if (partError == Errors.NONE.code()) { + if (partError != Errors.LEADER_NOT_AVAILABLE.code()) { int partition = partitionInfo.getInt(PARTITION_KEY_NAME); int leader = partitionInfo.getInt(LEADER_KEY_NAME); Node leaderNode = leader == -1 ? null : brokers.get(leader); -- 1.7.12.4