lib/waterdrop/config.rb in waterdrop-2.4.1 vs lib/waterdrop/config.rb in waterdrop-2.4.2
- old
+ new
@@ -75,10 +75,10 @@
private
# Propagates the kafka setting defaults unless they are already present
# This makes it easier to set some values that users usually don't change but still allows them
# to overwrite the whole hash if they want to
- # @param config [WaterDrop::Configurable::Node] config of this producer
+ # @param config [Karafka::Core::Configurable::Node] config of this producer
def merge_kafka_defaults!(config)
KAFKA_DEFAULTS.each do |key, value|
next if config.kafka.key?(key)
config.kafka[key] = value