We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dd98a35 commit 7e63f30Copy full SHA for 7e63f30
lib/rdkafka/producer.rb
@@ -62,6 +62,10 @@ def initialize(native_kafka, partitioner_name)
62
# Sets alternative set of configuration details that can be set per topic
63
# @note It is not allowed to re-set the same topic config twice because of the underlying
64
# librdkafka caching
65
+ # @param topic [String] The topic name
66
+ # @param config [Hash] config we want to use per topic basis
67
+ # @param config_hash [Integer] hash of the config. We expect it here instead of computing it,
68
+ # because it is already computed during the retrieval attempt in the `#produce` flow.
69
def set_topic_config(topic, config, config_hash)
70
# Ensure lock on topic reference just in case
71
@native_kafka.with_inner do |inner|
0 commit comments