Class: Kiev::Kafka::ContextExtractor

Inherits:
Object
  • Object
show all
Includes:
RequestId::Mixin
Defined in:
lib/kiev/kafka/context_extractor.rb

Constant Summary

Constants included from RequestId::Mixin

RequestId::Mixin::NEW_LINE

Instance Method Summary collapse

Methods included from RequestId::Mixin

#wrap_request_id

Instance Method Details

#call(message) ⇒ Object

Parameters:

  • message (Kafka::FetchedMessage) 


13
14
15
16
17
18
19
20
21
22
23
 
# 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