From dbebae6dd3d2f0c38dc68036a689536dbe5c1652 Mon Sep 17 00:00:00 2001 From: Artur Mkrtchyan Date: Fri, 29 May 2015 22:35:58 +0200 Subject: [PATCH] ReplicaNotAvailable can be safely ignored --- lib/poseidon/topic_metadata.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/poseidon/topic_metadata.rb b/lib/poseidon/topic_metadata.rb index 3265c4b..bdd96ec 100644 --- a/lib/poseidon/topic_metadata.rb +++ b/lib/poseidon/topic_metadata.rb @@ -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