class Kafka::Protocol::OffsetCommitRequest
Constants
- DEFAULT_RETENTION_TIME
This value signals to the broker that its default configuration should be used.
Public Class Methods
new(group_id:, generation_id:, member_id:, retention_time: DEFAULT_RETENTION_TIME, offsets:)
click to toggle source
# File lib/kafka/protocol/offset_commit_request.rb, line 21 def initialize(group_id:, generation_id:, member_id:, retention_time: DEFAULT_RETENTION_TIME, offsets:) @group_id = group_id @generation_id = generation_id @member_id = member_id @retention_time = retention_time @offsets = offsets end
Public Instance Methods
api_key()
click to toggle source
# File lib/kafka/protocol/offset_commit_request.rb, line 9 def api_key OFFSET_COMMIT_API end
api_version()
click to toggle source
# File lib/kafka/protocol/offset_commit_request.rb, line 13 def api_version 2 end
encode(encoder)
click to toggle source
# File lib/kafka/protocol/offset_commit_request.rb, line 29 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
response_class()
click to toggle source
# File lib/kafka/protocol/offset_commit_request.rb, line 17 def response_class OffsetCommitResponse end