Sha256: cd9dac1e860fa24c6acb8a47e2c9c53932573fcfe719afc528652cdfbcc474a1

Contents?: true

Size: 666 Bytes

Versions: 48

Compression:

Stored size: 666 Bytes

Contents

# frozen_string_literal: true

module Karafka
  # Patches to external components
  module Patches
    # Rdkafka related patches
    module Rdkafka
      # Rdkafka::Consumer patches
      module Consumer
        # A method that allows us to get the native kafka producer name
        # @return [String] producer instance name
        # @note We need this to make sure that we allocate proper dispatched events only to
        #   callback listeners that should publish them
        def name
          @name ||= ::Rdkafka::Bindings.rd_kafka_name(@native_kafka)
        end
      end
    end
  end
end

::Rdkafka::Consumer.include ::Karafka::Patches::Rdkafka::Consumer

Version data entries

48 entries across 48 versions & 1 rubygems

Version Path
karafka-2.1.4 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.1.3 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.1.2 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.1.1 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.1.0 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.41 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.40 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.39 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.38 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.37 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.36 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.35 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.34 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.33 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.32 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.31 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.30 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.29 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.28 lib/karafka/patches/rdkafka/consumer.rb
karafka-2.0.27 lib/karafka/patches/rdkafka/consumer.rb