Table of Contents - karafka-enterprise-0.0.1 Documentation
Classes and Modules
- Karafka
- Karafka::App
- Karafka::AssignmentStrategies
- Karafka::AssignmentStrategies::RoundRobin
- Karafka::AttributesMap
- Karafka::Backends
- Karafka::Backends::Inline
- Karafka::BaseConsumer
- Karafka::BaseResponder
- Karafka::Cli
- Karafka::Cli::Base
- Karafka::Cli::Console
- Karafka::Cli::Flow
- Karafka::Cli::Info
- Karafka::Cli::Install
- Karafka::Cli::Missingno
- Karafka::Cli::Server
- Karafka::CodeReloader
- Karafka::Connection
- Karafka::Connection::ApiAdapter
- Karafka::Connection::BatchDelegator
- Karafka::Connection::Builder
- Karafka::Connection::Client
- Karafka::Connection::Listener
- Karafka::Connection::MessageDelegator
- Karafka::Consumers
- Karafka::Consumers::BatchMetadata
- Karafka::Consumers::Callbacks
- Karafka::Consumers::Callbacks::ClassMethods
- Karafka::Consumers::Includer
- Karafka::Consumers::Responders
- Karafka::Consumers::SingleParams
- Karafka::Contracts
- Karafka::Contracts::Config
- Karafka::Contracts::ConsumerGroup
- Karafka::Contracts::ConsumerGroupTopic
- Karafka::Contracts::ResponderUsage
- Karafka::Contracts::ResponderUsageTopic
- Karafka::Contracts::ServerCliOptions
- Karafka::Errors
- Karafka::Fetcher
- Karafka::Helpers
- Karafka::Helpers::ClassMatcher
- Karafka::Helpers::ConfigRetriever
- Karafka::Helpers::Inflector
- Karafka::Helpers::MultiDelegator
- Karafka::Instrumentation
- Karafka::Instrumentation::Logger
- Karafka::Instrumentation::Monitor
- Karafka::Instrumentation::ProctitleListener
- Karafka::Instrumentation::StdoutListener
- Karafka::Params
- Karafka::Params::Builders
- Karafka::Params::Builders::BatchMetadata
- Karafka::Params::Builders::Params
- Karafka::Params::Builders::ParamsBatch
- Karafka::Params::Params
- Karafka::Params::ParamsBatch
- Karafka::Patches
- Karafka::Patches::RubyKafka
- Karafka::Persistence
- Karafka::Persistence::Client
- Karafka::Persistence::Consumers
- Karafka::Persistence::Topics
- Karafka::Process
- Karafka::Responders
- Karafka::Responders::Builder
- Karafka::Responders::Topic
- Karafka::Routing
- Karafka::Routing::Builder
- Karafka::Routing::ConsumerGroup
- Karafka::Routing::ConsumerMapper
- Karafka::Routing::Proxy
- Karafka::Routing::Router
- Karafka::Routing::Topic
- Karafka::Routing::TopicMapper
- Karafka::Serialization
- Karafka::Serialization::Json
- Karafka::Serialization::Json::Deserializer
- Karafka::Serialization::Json::Serializer
- Karafka::Server
- Karafka::Setup
- Karafka::Setup::Config
- Karafka::Setup::Configurators
- Karafka::Setup::Configurators::WaterDrop
- Karafka::Setup::Dsl
- Karafka::Status
- Object
Methods
- ::api_adapter — Karafka::AttributesMap
- ::bind_backend — Karafka::Consumers::Includer
- ::bind_batch_metadata — Karafka::Consumers::Includer
- ::bind_params — Karafka::Consumers::Includer
- ::bind_responders — Karafka::Consumers::Includer
- ::bind_to — Karafka::Cli::Base
- ::boot! — Karafka::App
- ::boot_file — Karafka
- ::call — Karafka::BaseResponder
- ::call — Karafka::Connection::BatchDelegator
- ::call — Karafka::Connection::Builder
- ::call — Karafka::Connection::MessageDelegator
- ::call — Karafka::Consumers::Includer
- ::clear — Karafka::Persistence::Consumers
- ::clear — Karafka::Persistence::Topics
- ::cli_commands — Karafka::Cli
- ::client — Karafka::Connection::ApiAdapter
- ::command — Karafka::Cli::Console
- ::consumer — Karafka::Connection::ApiAdapter
- ::consumer_group — Karafka::AttributesMap
- ::consumer_groups — Karafka::App
- ::consumer_groups — Karafka::Server
- ::consumption — Karafka::Connection::ApiAdapter
- ::core_root — Karafka
- ::current — Karafka::Persistence::Consumers
- ::current — Karafka::Persistence::Topics
- ::delegate — Karafka::Helpers::MultiDelegator
- ::desc — Karafka::Cli::Base
- ::exit_on_failure? — Karafka::Cli
- ::fetch — Karafka::Persistence::Consumers
- ::fetch — Karafka::Persistence::Topics
- ::fetch_for — Karafka::Connection::ApiAdapter
- ::find — Karafka::Routing::Router
- ::from_kafka_batch — Karafka::Params::Builders::BatchMetadata
- ::from_kafka_message — Karafka::Params::Builders::Params
- ::from_kafka_messages — Karafka::Params::Builders::ParamsBatch
- ::gem_root — Karafka
- ::included — Karafka::Consumers::Callbacks
- ::kafka_configs — Karafka::Connection::ApiAdapter
- ::logger — Karafka
- ::map — Karafka::Helpers::Inflector
- ::mark_message_as_processed — Karafka::Connection::ApiAdapter
- ::monitor — Karafka
- ::name — Karafka::Cli::Base
- ::new — Karafka::AssignmentStrategies::RoundRobin
- ::new — Karafka::BaseConsumer
- ::new — Karafka::BaseResponder
- ::new — Karafka::Cli::Base
- ::new — Karafka::Cli::Install
- ::new — Karafka::CodeReloader
- ::new — Karafka::Connection::Client
- ::new — Karafka::Connection::Listener
- ::new — Karafka::Helpers::ClassMatcher
- ::new — Karafka::Helpers::MultiDelegator
- ::new — Karafka::Instrumentation::Logger
- ::new — Karafka::Instrumentation::Monitor
- ::new — Karafka::Params::Params
- ::new — Karafka::Params::ParamsBatch
- ::new — Karafka::Process
- ::new — Karafka::Responders::Builder
- ::new — Karafka::Responders::Topic
- ::new — Karafka::Routing::Builder
- ::new — Karafka::Routing::ConsumerGroup
- ::new — Karafka::Routing::Proxy
- ::new — Karafka::Routing::Topic
- ::option — Karafka::Cli::Base
- ::pause — Karafka::Connection::ApiAdapter
- ::prepare — Karafka::Cli
- ::process — Karafka::Server
- ::read — Karafka::Persistence::Client
- ::reload — Karafka::App
- ::root — Karafka
- ::run — Karafka::Server
- ::run_supervised — Karafka::Server
- ::sanitize — Karafka::Connection::ApiAdapter
- ::setup — Karafka::Setup::Config
- ::setup_components — Karafka::Setup::Config
- ::stop_supervised — Karafka::Server
- ::subscribe — Karafka::Connection::ApiAdapter
- ::to — Karafka::Helpers::MultiDelegator
- ::topic — Karafka::BaseResponder
- ::topic — Karafka::AttributesMap
- ::validate! — Karafka::Setup::Config
- ::write — Karafka::Persistence::Client
- #active — Karafka::Routing::Builder
- #active? — Karafka::Routing::ConsumerGroup
- #async? — Karafka::Responders::Topic
- #available_events — Karafka::Instrumentation::Monitor
- #build — Karafka::Responders::Builder
- #build — Karafka::Routing::Topic
- #call — Karafka::BaseConsumer
- #call — Karafka::BaseResponder
- #call — Karafka::Cli::Base
- #call — Karafka::Cli::Console
- #call — Karafka::Cli::Flow
- #call — Karafka::Cli::Info
- #call — Karafka::Cli::Install
- #call — Karafka::Cli::Missingno
- #call — Karafka::Cli::Server
- #call — Karafka::Connection::Listener
- #call — Karafka::Fetcher
- #call — Karafka::Routing::ConsumerMapper
- #call — Karafka::Serialization::Json::Deserializer
- #call — Karafka::Serialization::Json::Serializer
- #call — Karafka::Setup::Configurators::WaterDrop
- #call — Karafka::Consumers::Callbacks
- #clean — Karafka::Cli::Server
- #clear — Karafka::Routing::Builder
- #client — Karafka::BaseConsumer
- #client — Karafka::Connection::Listener
- #config — Karafka::Setup::Dsl
- #config_retriever_for — Karafka::Helpers::ConfigRetriever
- #consume — Karafka::BaseConsumer
- #consumer_group — Karafka::Routing::Builder
- #consumer_loop — Karafka::Patches::RubyKafka
- #daemonize — Karafka::Cli::Server
- #deliver! — Karafka::BaseResponder
- #deserialize — Karafka::Params::Params
- #deserialize! — Karafka::Params::ParamsBatch
- #deserialized? — Karafka::Params::Params
- #draw — Karafka::Routing::Builder
- #each — Karafka::Params::ParamsBatch
- #ensure_dir_exists — Karafka::Instrumentation::Logger
- #fetch_loop — Karafka::Connection::Client
- #fetch_loop — Karafka::Connection::Listener
- #file — Karafka::Instrumentation::Logger
- #find — Karafka::Routing::Router
- #first — Karafka::Params::ParamsBatch
- #format — Karafka::Cli::Flow
- #incoming — Karafka::Routing::TopicMapper
- #kafka_consumer — Karafka::Connection::Client
- #kafka_uri? — Karafka::Contracts::ConsumerGroup
- #last — Karafka::Params::ParamsBatch
- #listeners — Karafka::Fetcher
- #log_path — Karafka::Instrumentation::Logger
- #mark_as_consumed — Karafka::Connection::Client
- #mark_as_consumed! — Karafka::Connection::Client
- #match — Karafka::Helpers::ClassMatcher
- #method_missing — Karafka::Routing::Proxy
- #name — Karafka::Helpers::ClassMatcher
- #notice_signal — Karafka::Process
- #on_app_initializing — Karafka::Instrumentation::ProctitleListener
- #on_app_initializing — Karafka::Instrumentation::StdoutListener
- #on_app_running — Karafka::Instrumentation::ProctitleListener
- #on_app_running — Karafka::Instrumentation::StdoutListener
- #on_app_stopping — Karafka::Instrumentation::ProctitleListener
- #on_app_stopping — Karafka::Instrumentation::StdoutListener
- #on_app_stopping_error — Karafka::Instrumentation::StdoutListener
- #on_backends_inline_process — Karafka::Instrumentation::StdoutListener
- #on_connection_batch_delegator_call — Karafka::Instrumentation::StdoutListener
- #on_connection_client_fetch_loop_error — Karafka::Instrumentation::StdoutListener
- #on_connection_listener_fetch_loop — Karafka::CodeReloader
- #on_connection_listener_fetch_loop_error — Karafka::Instrumentation::StdoutListener
- #on_connection_message_delegator_call — Karafka::Instrumentation::StdoutListener
- #on_consumers_responders_respond_with — Karafka::Instrumentation::StdoutListener
- #on_fetcher_call_error — Karafka::Instrumentation::StdoutListener
- #on_params_params_deserialize — Karafka::Instrumentation::StdoutListener
- #on_params_params_deserialize_error — Karafka::Instrumentation::StdoutListener
- #on_process_notice_signal — Karafka::Instrumentation::StdoutListener
- #outgoing — Karafka::Routing::TopicMapper
- #params — Karafka::Consumers::SingleParams
- #pause — Karafka::Connection::Client
- #payload — Karafka::Params::Params
- #payloads — Karafka::Params::ParamsBatch
- #process — Karafka::Backends::Inline
- #producer — Karafka::BaseResponder
- #publish_event — Karafka::Patches::RubyKafka
- #rails? — Karafka::Cli::Install
- #registered? — Karafka::Responders::Topic
- #reload — Karafka::CodeReloader
- #reload — Karafka::Routing::Builder
- #reload! — Object
- #reload_with_rails — Karafka::CodeReloader
- #reload_without_rails — Karafka::CodeReloader
- #required? — Karafka::Responders::Topic
- #respond — Karafka::BaseResponder
- #respond_to — Karafka::BaseResponder
- #respond_to_missing? — Karafka::Routing::Proxy
- #respond_with — Karafka::Consumers::Responders
- #responder — Karafka::Routing::Topic
- #same_scope? — Karafka::Helpers::ClassMatcher
- #scope — Karafka::Helpers::ClassMatcher
- #scope_of — Karafka::Helpers::ClassMatcher
- #serializer — Karafka::Responders::Topic
- #setproctitle — Karafka::Instrumentation::ProctitleListener
- #setup — Karafka::Setup::Dsl
- #size — Karafka::Params::ParamsBatch
- #stop — Karafka::Connection::Client
- #subscribe — Karafka::Instrumentation::Monitor
- #supervise — Karafka::Process
- #target — Karafka::Instrumentation::Logger
- #to_a — Karafka::Params::ParamsBatch
- #to_h — Karafka::Responders::Topic
- #to_h — Karafka::Routing::ConsumerGroup
- #to_h — Karafka::Routing::Topic
- #topic — Karafka::Routing::Builder
- #topic= — Karafka::Routing::ConsumerGroup
- #topics — Karafka::Cli::Flow
- #trap_signal — Karafka::Process
- #valid_certificate? — Karafka::Contracts::ConsumerGroup
- #valid_private_key? — Karafka::Contracts::ConsumerGroup
- #validate! — Karafka::Cli::Server
- #validate_options! — Karafka::BaseResponder
- #validate_usage! — Karafka::BaseResponder