class Karafka::App

App class

def boot!

Raises:
  • (Karafka::Errors::InvalidConfiguration) - raised when configuration
def boot!
  Setup::Config.validate!
  Setup::Config.setup_components
  Callbacks.after_init(Karafka::App.config)
end

def consumer_groups

Returns:
  • (Karafka::Routing::Builder) - consumers builder instance
def consumer_groups
  Routing::Builder.instance
end