Sha256: 893c0ab0544c9813c5f1be271ba1ad6f9b5047bacf5849808869241bec0e7778
Contents?: true
Size: 517 Bytes
Versions: 6
Compression:
Stored size: 517 Bytes
Contents
# frozen_string_literal: true
module WaterDrop
# Patches to external components
module Patches
# Rdkafka related patches
module Rdkafka
# Rdkafka::Producer patches
module Producer
# Adds a method that allows us to get the native kafka producer name
# @return [String] producer instance name
def name
::Rdkafka::Bindings.rd_kafka_name(@native_kafka)
end
end
end
end
end
::Rdkafka::Producer.include ::WaterDrop::Patches::Rdkafka::Producer
Version data entries
6 entries across 6 versions & 1 rubygems