module Kafka::Compression

def self.codecs
  CODECS.keys
end

def self.find_codec(name)
  codec = CODECS.fetch(name) do
    raise "Unknown compression codec #{name}"
  end
  codec.load
  codec
end

def self.find_codec_by_id(codec_id)
  codec_name = CODEC_NAMES.fetch(codec_id) do
    raise "Unknown codec id #{codec_id}"
  end
  find_codec(codec_name)
end