Sha256: 5c31e17955dcf34babccab32ed28e4595b494ad86f3049ce0a2f3e4b18444664
Contents?: true
Size: 403 Bytes
Versions: 19
Compression:
Stored size: 403 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Deserializers
# Default message key deserializer
class Key
# @param metadata [Karafka::Messages::Metadata] metadata object from which we obtain the
# `#raw_key`
# @return [String, nil] expected message key in a string format or nil if no key
def call(metadata)
metadata.raw_key
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems