class Kafka::ZstdCodec

Public Instance Methods

codec_id() click to toggle source
# File lib/kafka/zstd_codec.rb, line 5
def codec_id
  4
end
compress(data) click to toggle source
# File lib/kafka/zstd_codec.rb, line 19
def compress(data)
  Zstd.compress(data)
end
decompress(data) click to toggle source
# File lib/kafka/zstd_codec.rb, line 23
def decompress(data)
  Zstd.decompress(data)
end
load() click to toggle source
# File lib/kafka/zstd_codec.rb, line 13
def load
  require "zstd-ruby"
rescue LoadError
  raise LoadError, "using zstd compression requires adding a dependency on the `zstd-ruby` gem to your Gemfile."
end
produce_api_min_version() click to toggle source
# File lib/kafka/zstd_codec.rb, line 9
def produce_api_min_version
  7
end