module Kiev::Kafka

Public Class Methods

extract_context(message) click to toggle source

@param [Kafka::FetchedMessage] message

# File lib/kiev/kafka.rb, line 12
def extract_context(message)
  Kiev::Kafka::ContextExtractor.new.call(message)
end
inject_context(headers = {}) click to toggle source

@param [Hash] headers

# File lib/kiev/kafka.rb, line 17
def inject_context(headers = {})
  Kiev::Kafka::ContextInjector.new.call(headers)
end