Class: Kafka::Protocol::LeaveGroupRequest

6
7
8
9

# File 'lib/kafka/protocol/leave_group_request.rb', line 6
def initialize(group_id:, member_id:)
 @group_id = group_id
 @member_id = member_id
end

11
12
13

# File 'lib/kafka/protocol/leave_group_request.rb', line 11
def api_key
 LEAVE_GROUP_API 
end

19
20
21
22

# File 'lib/kafka/protocol/leave_group_request.rb', line 19
def encode(encoder)
 encoder.write_string(@group_id)
 encoder.write_string(@member_id)
end

15
16
17

# File 'lib/kafka/protocol/leave_group_request.rb', line 15
def response_class
 LeaveGroupResponse 
end