Method: Kafka::Protocol::OffsetFetchRequest#api_version

Defined in:
lib/kafka/protocol/offset_fetch_request.rb

#api_version ⇒ Object

setting topics to nil fetches all offsets for a consumer group and that feature is only available in API version 2+



17
18
19
 
# File 'lib/kafka/protocol/offset_fetch_request.rb', line 17

def api_version
  @topics.nil? ? 2 : 1
end