Sha256: 2ebc9dc5a393f11de4dbc5f38bceccbcf3d6056b90041625d7f7b007261bcc40
Contents?: true
Size: 496 Bytes
Versions: 8
Compression:
Stored size: 496 Bytes
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