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