class Kiev::Kafka::ContextExtractor

Public Instance Methods

call(message) click to toggle source

@param [Kafka::FetchedMessage] message

# File lib/kiev/kafka/context_extractor.rb, line 13
def call(message)
  context = Kiev::Kafka::MessageContext.new(message)
  context_reader = Kiev::ContextReader.new(context)
  wrap_request_id(context_reader) {}

  Kiev[:message_key] = message.key

  Config.instance.jobs_propagated_fields.each do |key|
    Kiev[key] = context_reader[key]
  end
end