Class: Karafka::Deserializers::Key

Inherits:

Object

Object
Karafka::Deserializers::Key

show all

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`^?



10
11
12

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

def call(metadata)
  metadata.raw_key
end