Module: Kiev::Kafka

Defined in:: lib/kiev/kafka.rb,
lib/kiev/kafka/message_context.rb,
lib/kiev/kafka/context_injector.rb,
lib/kiev/kafka/context_extractor.rb

Defined Under Namespace

Classes: ContextExtractor, ContextInjector, MessageContext

Class Method Summary collapse

Class Method Details

.extract_context(message) ⇒ `Object`

Parameters:

message (Kafka::FetchedMessage)



12
13
14

# File 'lib/kiev/kafka.rb', line 12

def extract_context(message)
  Kiev::Kafka::ContextExtractor.new.call(message)
end

.inject_context(headers = {}) ⇒ `Object`

Parameters:

headers (Hash) (defaults to: {})



17
18
19

# File 'lib/kiev/kafka.rb', line 17

def inject_context(headers = {})
  Kiev::Kafka::ContextInjector.new.call(headers)
end