class Kafka::Protocol::RequestMessage

Constants

API_VERSION

Public Class Methods

new(api_key:, api_version: API_VERSION, correlation_id:, client_id:, request:) click to toggle source
# File lib/kafka/protocol/request_message.rb, line 8
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

Public Instance Methods

encode(encoder) click to toggle source
# File lib/kafka/protocol/request_message.rb, line 16
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