module Poseidon::Compression

@api private

Constants

CODECS

Public Class Methods

find_codec(codec_id) click to toggle source

Fetches codec module for codec_id cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Compression

@param [Integer] codec_id codec's as defined by the Kafka Protocol @return [Module] codec module for codec_id

@private

# File lib/poseidon/compression.rb, line 22
def self.find_codec(codec_id)
  codec = CODECS[codec_id]
  if codec.nil?
    raise UnrecognizedCompressionCodec, codec_id
  end
  codec
end