Method: Kafka::Protocol::Message#decompress

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

#decompress ⇒ Array<Kafka::Protocol::Message>

Returns:



55
56
57
58
59
60
61
62
63
64
 
# File 'lib/kafka/protocol/message.rb', line 55

def decompress
  codec = Compression.find_codec_by_id(@codec_id)

  # For some weird reason we need to cut out the first 20 bytes.
  data = codec.decompress(value)
  message_set_decoder = Decoder.from_string(data)
  message_set = MessageSet.decode(message_set_decoder)

  correct_offsets(message_set.messages)
end