Method: Kafka::Message#encode

Defined in:
lib/kafka/message.rb

#encode(compression = NO_COMPRESSION) ⇒ Object 



121
122
123
124
125
126
127
128
129
 
# File 'lib/kafka/message.rb', line 121

def encode(compression = NO_COMPRESSION)
  @compression = compression

  self.payload = asciify_payload
  self.payload = compress_payload if compression?

  data = magic_and_compression + [calculate_checksum].pack("N") + payload
  [data.length].pack("N") + data
end