Contents

# frozen_string_literal: true

require_relative "base"

module Kiev
  module Kafka
    require_relative "kafka/context_extractor"
    require_relative "kafka/context_injector"

    class << self
      # @param [Kafka::FetchedMessage] message
      def extract_context(message)
        Kiev::Kafka::ContextExtractor.new.call(message)
      end

      # @param [Hash] headers
      def inject_context(headers = {})
        Kiev::Kafka::ContextInjector.new.call(headers)
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
kiev-4.9.0	lib/kiev/kafka.rb
kiev-4.8.3	lib/kiev/kafka.rb
kiev-4.8.2	lib/kiev/kafka.rb
kiev-4.8.1	lib/kiev/kafka.rb
kiev-4.8.0	lib/kiev/kafka.rb
kiev-4.7.0	lib/kiev/kafka.rb
kiev-4.6.0	lib/kiev/kafka.rb
kiev-4.5.0	lib/kiev/kafka.rb