Sha256: ea9e94bbe9ae0ddf2e659e3594bed8cccb51da91f7d2147b7c47a0d9e3f27ad3
Contents?: true
Size: 460 Bytes
Versions: 18
Compression:
Stored size: 460 Bytes
Contents
# frozen_string_literal: true
module Kafka
class ZstdCodec
def codec_id
4
end
def produce_api_min_version
7
end
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
def compress(data)
Zstd.compress(data)
end
def decompress(data)
Zstd.decompress(data)
end
end
end
Version data entries
18 entries across 18 versions & 3 rubygems