class Karafka::App

App class

Public Class Methods

boot!() click to toggle source

Sets up all the internal components and bootstrap whole app We need to know details about consumers in order to setup components, that's why we don't setup them after std setup is done @raise [Karafka::Errors::InvalidConfigurationError] raised when configuration

doesn't match with the config contract
# File lib/karafka/app.rb, line 14
def boot!
  initialize!
  Setup::Config.validate!
  Setup::Config.setup_components
  initialized!
end
consumer_groups() click to toggle source

@return [Karafka::Routing::Builder] consumers builder instance

# File lib/karafka/app.rb, line 22
def consumer_groups
  config.internal.routing_builder
end
reload() click to toggle source

Triggers reload of all cached Karafka app components, so we can use in-process in-development hot code reloading without Karafka process restart

# File lib/karafka/app.rb, line 28
def reload
  Karafka::Persistence::Consumers.clear
  Karafka::Persistence::Topics.clear
  config.internal.routing_builder.reload
end