From f3945fa5c3bc364c5befe884e080f5fbbe5e4445 Mon Sep 17 00:00:00 2001 From: ABaldwinHunter Date: Fri, 25 Sep 2015 14:54:42 -0400 Subject: [PATCH] update to pass over unavailable leaders --- lib/poseidon/topic_metadata.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/poseidon/topic_metadata.rb b/lib/poseidon/topic_metadata.rb index 3265c4b..61730aa 100644 --- a/lib/poseidon/topic_metadata.rb +++ b/lib/poseidon/topic_metadata.rb @@ -18,7 +18,7 @@ def initialize(struct=nil) end # Write a binary representation of the TopicMetadata to buffer - # + # # @param [RequestBuffer] buffer # @return [nil] def write(buffer) @@ -56,7 +56,7 @@ def partition_count def available_partitions @available_partitions ||= struct.partitions.select do |partition| - partition.error == 0 && partition.leader != -1 + (partition.error == Errors::NO_ERROR_CODE || Errors::ERROR_CODES[partition.error] == Errors::ReplicaNotAvailable) && partition.leader != -1 end end