module Kafka::Compression

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