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