Class: Karafka::Deserializers::Key

Inherits:

Object

Object
Karafka::Deserializers::Key

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

Overview

Default message key deserializer

Instance Method Summary collapse

#call(metadata) ⇒ String^?

Expected message key in a string format or nil if no key.

Instance Method Details

#call(metadata) ⇒ `String`^?

Returns expected message key in a string format or nil if no key.

Parameters:

metadata (Karafka::Messages::Metadata) —

metadata object from which we obtain the ‘#raw_key`

Returns:

(String, nil) —

expected message key in a string format or nil if no key



10
11
12

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

def call(metadata)
  metadata.raw_key
end