module Kafka::Compression
Constants
- CODECS_BY_ID
- CODECS_BY_NAME
Public Class Methods
codecs()
click to toggle source
# File lib/kafka/compression.rb, line 21 def self.codecs CODECS_BY_NAME.keys end
find_codec(name)
click to toggle source
# File lib/kafka/compression.rb, line 25 def self.find_codec(name) codec = CODECS_BY_NAME.fetch(name) do raise "Unknown compression codec #{name}" end codec.load codec end
find_codec_by_id(codec_id)
click to toggle source
# File lib/kafka/compression.rb, line 35 def self.find_codec_by_id(codec_id) codec = CODECS_BY_ID.fetch(codec_id) do raise "Unknown codec id #{codec_id}" end codec.load codec end