class Kafka::Protocol::LeaveGroupRequest
Public Class Methods
new(group_id:, member_id:)
click to toggle source
# 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
Public Instance Methods
api_key()
click to toggle source
# File lib/kafka/protocol/leave_group_request.rb, line 11 def api_key LEAVE_GROUP_API end
encode(encoder)
click to toggle source
# File lib/kafka/protocol/leave_group_request.rb, line 19 def encode(encoder) encoder.write_string(@group_id) encoder.write_string(@member_id) end
response_class()
click to toggle source
# File lib/kafka/protocol/leave_group_request.rb, line 15 def response_class LeaveGroupResponse end