Class: Karafka::Deserializers::Headers

Inherits:

Object

Object
Karafka::Deserializers::Headers

show all

Defined in:: lib/karafka/deserializers/headers.rb

Overview

Default message headers deserializer

Instance Method Summary collapse

#call(metadata) ⇒ Hash

Expected message headers hash.

Instance Method Details

#call(metadata) ⇒ `Hash`

Returns expected message headers hash.

Parameters:

metadata (Karafka::Messages::Metadata) —

metadata object from which we obtain the ‘#raw_headers`

Returns:

(Hash) —

expected message headers hash



10
11
12

# File 'lib/karafka/deserializers/headers.rb', line 10

def call(metadata)
  metadata.raw_headers
end