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