Class: Karafka::Serialization::Json::Deserializer

Inherits:

Object

• Object
• Karafka::Serialization::Json::Deserializer

Defined in:

lib/karafka/serialization/json/deserializer.rb

Overview

Default Karafka Json deserializer for loading JSON data.

Instance Method Summary

• #call(message) ⇒ Hash

  Hash with deserialized JSON data.

Instance Method Details

#call(message) ⇒ Hash

Returns hash with deserialized JSON data.

Parameters:

• message (Karafka::Messages::Message) —

  Message object that we want to deserialize

Returns:

• (Hash) —

  hash with deserialized JSON data

# File 'lib/karafka/serialization/json/deserializer.rb', line 12

def call(message)
  # nil payload can be present for example for tombstone messages
  message.raw_payload.nil? ? nil : ::JSON.parse(message.raw_payload)
end