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