class Kiev::Kafka::ContextInjector

Public Instance Methods

call(headers = {}) click to toggle source

@param [Hash] headers Injects context headers @return [Hash]

# File lib/kiev/kafka/context_injector.rb, line 11
def call(headers = {})
  Kiev::SubrequestHelper.payload.each do |key, value|
    field_key = Kiev::Config::DEFAULT_HTTP_PROPAGATED_FIELDS.fetch(key.to_sym, key)
    headers[field_key] = value
  end
  headers
end