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