Method: Kafka::Protocol::RequestMessage#encode

Defined in:
lib/kafka/protocol/request_message.rb

#encode(encoder) ⇒ Object 


16
17
18
19
20
21
22
23
 
# 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