class Kafka::Protocol::SyncGroupRequest
Public Class Methods
new(group_id:, generation_id:, member_id:, group_assignment: {})
click to toggle source
# File lib/kafka/protocol/sync_group_request.rb, line 6 def initialize(group_id:, generation_id:, member_id:, group_assignment: {}) @group_id = group_id @generation_id = generation_id @member_id = member_id @group_assignment = group_assignment end
Public Instance Methods
api_key()
click to toggle source
# File lib/kafka/protocol/sync_group_request.rb, line 13 def api_key SYNC_GROUP_API end
encode(encoder)
click to toggle source
# File lib/kafka/protocol/sync_group_request.rb, line 21 def encode(encoder) encoder.write_string(@group_id) encoder.write_int32(@generation_id) encoder.write_string(@member_id) encoder.write_array(@group_assignment) do |member_id, member_assignment| encoder.write_string(member_id) encoder.write_bytes(Encoder.encode_with(member_assignment)) end end
response_class()
click to toggle source
# File lib/kafka/protocol/sync_group_request.rb, line 17 def response_class SyncGroupResponse end