Module: Karafka::Patches::Rdkafka::Consumer

Defined in:: lib/karafka/patches/rdkafka/consumer.rb

Overview

Rdkafka::Consumer patches

Instance Method Summary collapse

#name ⇒ String

A method that allows us to get the native kafka producer name.

Instance Method Details

#name ⇒ `String`

Note:

We need this to make sure that we allocate proper dispatched events only to callback listeners that should publish them

A method that allows us to get the native kafka producer name

Returns:

(String) —

producer instance name



14
15
16

# File 'lib/karafka/patches/rdkafka/consumer.rb', line 14

def name
  @name ||= ::Rdkafka::Bindings.rd_kafka_name(@native_kafka)
end