Module: Karafka::Connection

Defined in:

lib/karafka/connection/client.rb,
lib/karafka/connection/proxy.rb,
lib/karafka/connection/listener.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,
lib/karafka/connection/consumer_group_coordinator.rb

Overview

Namespace for Kafka connection related logic

Defined Under Namespace

Classes: Client, ConsumerGroupCoordinator, Listener, ListenersBatch, MessagesBuffer, PausesManager, Proxy, RawMessagesBuffer, RebalanceManager