Class: Kafka::Protocol::SyncGroupRequest

6
7
8
9
10
11

# 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

13
14
15

# File 'lib/kafka/protocol/sync_group_request.rb', line 13
def api_key
 SYNC_GROUP_API 
end

21
22
23
24
25
26
27
28
29
30

# 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

17
18
19

# File 'lib/kafka/protocol/sync_group_request.rb', line 17
def response_class
 SyncGroupResponse 
end