Skip to content

Commit 93b8b16

Browse files
authored
Merge pull request #535 from zendesk/dasch/cleanup-sdfadsfadsf
Extract ApiInfo#version_supported?
2 parents d837e26 + 4922e4e commit 93b8b16

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

lib/kafka/cluster.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ def supports_api?(api_key, version = nil)
6060
elsif version.nil?
6161
return true
6262
else
63-
return (info.min_version..info.max_version).include?(version)
63+
return info.version_supported?(version)
6464
end
6565
end
6666

lib/kafka/protocol/api_versions_response.rb

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,10 @@ def api_name
1313
Protocol.api_name(api_key)
1414
end
1515

16+
def version_supported?(version)
17+
(min_version..max_version).include?(version)
18+
end
19+
1620
def to_s
1721
"#{api_name}=#{min_version}..#{max_version}"
1822
end

0 commit comments

Comments
 (0)