diff --git a/lib/kafka/cluster.rb b/lib/kafka/cluster.rb
index e80d30402..b2b321fbf 100644
--- a/lib/kafka/cluster.rb
+++ b/lib/kafka/cluster.rb
@@ -60,7 +60,7 @@ def supports_api?(api_key, version = nil)
       elsif version.nil?
         return true
       else
-        return (info.min_version..info.max_version).include?(version)
+        return info.version_supported?(version)
       end
     end
 
diff --git a/lib/kafka/protocol/api_versions_response.rb b/lib/kafka/protocol/api_versions_response.rb
index 6623640f6..b4d2fd4c7 100644
--- a/lib/kafka/protocol/api_versions_response.rb
+++ b/lib/kafka/protocol/api_versions_response.rb
@@ -13,6 +13,10 @@ def api_name
           Protocol.api_name(api_key)
         end
 
+        def version_supported?(version)
+          (min_version..max_version).include?(version)
+        end
+
         def to_s
           "#{api_name}=#{min_version}..#{max_version}"
         end