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