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