Sha256: f69bb2ad4ee4662f10bd65c4a97065d02f12785d6b5f0644e040450e4490e5b4
Contents?: true
Size: 632 Bytes
Versions: 30
Compression:
Stored size: 632 Bytes
Contents
module Kafka
module Protocol
class OffsetFetchRequest
def initialize(group_id:, topics:)
@group_id = group_id
@topics = topics
end
def api_key
9
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
30 entries across 30 versions & 1 rubygems