Class: Karafka::Deserializers::Payload

Inherits:

Object

• Object
• Karafka::Deserializers::Payload

Defined in:

lib/karafka/deserializers/payload.rb

Overview

Default Karafka Json deserializer for loading JSON data in payload.

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/deserializers/payload.rb', line 10

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