Sha256: 44959c16e89d05eecb46580b5ba012ea0a4548358d21e9c10f83b2b8fe21e33b
Contents?: true
Size: 829 Bytes
Versions: 14
Compression:
Stored size: 829 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class OffsetFetchRequest
def initialize(group_id:, topics:)
@group_id = group_id
@topics = topics
end
def api_key
OFFSET_FETCH_API
end
# setting topics to nil fetches all offsets for a consumer group
# and that feature is only available in API version 2+
def api_version
@topics.nil? ? 2 : 1
end
def response_class
OffsetFetchResponse
end
def encode(encoder)
encoder.write_string(@group_id)
encoder.write_array(@topics) do |topic, partitions|
encoder.write_string(topic)
encoder.write_array(partitions) do |partition|
encoder.write_int32(partition)
end
end
end
end
end
end
Version data entries
14 entries across 14 versions & 3 rubygems