Module: Karafka::Connection

Defined in:

lib/karafka/connection/client.rb,
lib/karafka/connection/proxy.rb,
lib/karafka/connection/status.rb,
lib/karafka/connection/manager.rb,
lib/karafka/connection/listener.rb,
lib/karafka/connection/conductor.rb,
lib/karafka/connection/pauses_manager.rb,
lib/karafka/connection/listeners_batch.rb,
lib/karafka/connection/messages_buffer.rb,
lib/karafka/connection/rebalance_manager.rb,
lib/karafka/connection/raw_messages_buffer.rb

Overview

Namespace for Kafka connection related logic

Defined Under Namespace

Classes: Client, Conductor, Listener, ListenersBatch, Manager, MessagesBuffer, PausesManager, Proxy, RawMessagesBuffer, RebalanceManager, Status