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