Class: Sbmt::KafkaConsumer::Serialization::NullDeserializer

Inherits:
BaseDeserializer show all
Defined in:
lib/sbmt/kafka_consumer/serialization/null_deserializer.rb

Instance Attribute Summary

Attributes inherited from BaseDeserializer

#skip_decoding_error

Instance Method Summary collapse

Methods inherited from BaseDeserializer

#initialize

Constructor Details

This class inherits a constructor from Sbmt::KafkaConsumer::Serialization::BaseDeserializer

Instance Method Details

#call(message) ⇒ Object



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

def call(message)
  message.raw_payload
end