Sha256: 5c7cf600041f2c8a2240c516b4bbb4ef426837361ce588781533cfa2120061c5
Contents?: true
Size: 414 Bytes
Versions: 22
Compression:
Stored size: 414 Bytes
Contents
# frozen_string_literal: true
module Sbmt
module KafkaConsumer
module Serialization
class BaseDeserializer
attr_reader :skip_decoding_error
def initialize(skip_decoding_error: false)
@skip_decoding_error = skip_decoding_error
end
def call(_message)
raise NotImplementedError, "Implement this in a subclass"
end
end
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems