Module: Karafka::Pro::Setup::DefaultsInjector

Defined in:
lib/karafka/pro/setup/defaults_injector.rb

Overview

Pro defaults injector that extends the OSS defaults with Pro-specific settings

Instance Method Summary collapse

Instance Method Details

#consumer(kafka_config) ⇒ Object

Enriches consumer kafka config with Pro-specific defaults

Parameters:

  • kafka_config (Hash) —

    kafka scoped config



58
59
60
61
62
63
64
65
66
 
# File 'lib/karafka/pro/setup/defaults_injector.rb', line 58

def consumer(kafka_config)
  super

  CONSUMER_KAFKA_DEFAULTS.each do |key, value|
    next if kafka_config.key?(key)

    kafka_config[key] = value
  end
end

#managed_keys ⇒ Set<Symbol>

Pro actively manages these keys via its own DefaultsInjector so users are allowed to set them if needed.

Returns:

  • (Set<Symbol>) —

    empty set since Pro handles these keys



52
53
54
 
# File 'lib/karafka/pro/setup/defaults_injector.rb', line 52

def managed_keys
  @managed_keys ||= Set.new
end