Sha256: ad807b4393b15389b500a1d6a89550d7c47a6edcbf0b76ed87c2b1d14f8a1236
Contents?: true
Size: 678 Bytes
Versions: 35
Compression:
Stored size: 678 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
def api_version
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
35 entries across 35 versions & 2 rubygems