lib/waterdrop/config.rb in waterdrop-2.3.3 vs lib/waterdrop/config.rb in waterdrop-2.4.0

- old
+ new

@@ -3,11 +3,11 @@ # Configuration and descriptions are based on the delivery boy zendesk gem # @see https://github.com/zendesk/delivery_boy module WaterDrop # Configuration object for setting up all options required by WaterDrop class Config - include Configurable + include ::Karafka::Core::Configurable # Defaults for kafka settings, that will be overwritten only if not present already KAFKA_DEFAULTS = { 'client.id': 'waterdrop' }.freeze @@ -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 [Dry::Configurable::Config] dry config of this producer + # @param config [WaterDrop::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