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