Class: Sbmt::KafkaConsumer::Serialization::BaseDeserializer

Inherits:
Object
  • Object
show all
Defined in:
lib/sbmt/kafka_consumer/serialization/base_deserializer.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(skip_decoding_error: false) ⇒ BaseDeserializer

Returns a new instance of BaseDeserializer.



9
10
11
 
# File 'lib/sbmt/kafka_consumer/serialization/base_deserializer.rb', line 9

def initialize(skip_decoding_error: false)
  @skip_decoding_error = skip_decoding_error
end

Instance Attribute Details

#skip_decoding_error ⇒ Object (readonly)

Returns the value of attribute skip_decoding_error.



7
8
9
 
# File 'lib/sbmt/kafka_consumer/serialization/base_deserializer.rb', line 7

def skip_decoding_error
  @skip_decoding_error
end

Instance Method Details

#call(_message) ⇒ Object

Raises:

  • (NotImplementedError) 


13
14
15
 
# File 'lib/sbmt/kafka_consumer/serialization/base_deserializer.rb', line 13

def call(_message)
  raise NotImplementedError, "Implement this in a subclass"
end