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