lib/kafka/protocol/api_versions_response.rb in ruby-kafka-0.5.2 vs lib/kafka/protocol/api_versions_response.rb in ruby-kafka-0.5.3
- old
+ new
@@ -11,9 +11,13 @@
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
def inspect