class Kafka::Protocol::RequestMessage

def encode(encoder)
  encoder.write_int16(@api_key)
  encoder.write_int16(@api_version)
  encoder.write_int32(@correlation_id)
  encoder.write_string(@client_id)
  @request.encode(encoder)
end

def initialize(api_key:, api_version: API_VERSION, correlation_id:, client_id:, request:)
  @api_key = api_key
  @api_version = api_version
  @correlation_id = correlation_id
  @client_id = client_id
  @request = request
end