Sha256: 602fb19c9025bd4286250bdbad024e35580788e1cadacfca315d8423ce1fa647
Contents?: true
Size: 1023 Bytes
Versions: 6
Compression:
Stored size: 1023 Bytes
Contents
module Kafka
module Protocol
class OffsetCommitRequest
def api_key
8
end
def api_version
2
end
def response_class
OffsetCommitResponse
end
def initialize(group_id:, generation_id:, member_id:, retention_time: 0, offsets:)
@group_id = group_id
@generation_id = generation_id
@member_id = member_id
@retention_time = retention_time
@offsets = offsets
end
def encode(encoder)
encoder.write_string(@group_id)
encoder.write_int32(@generation_id)
encoder.write_string(@member_id)
encoder.write_int64(@retention_time)
encoder.write_array(@offsets) do |topic, partitions|
encoder.write_string(topic)
encoder.write_array(partitions) do |partition, offset|
encoder.write_int32(partition)
encoder.write_int64(offset)
encoder.write_string(nil) # metadata
end
end
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems