class Karafka::Persistence::Client

Persistence layer to store current thread messages consumer client for further use

def self.read

Raises:
  • (Karafka::Errors::MissingConsumer) - raised when no thread messages consumer

Returns:
  • (Karafka::Connection::Client) - persisted messages consumer client 
def self.read
  Thread.current[PERSISTENCE_SCOPE] || raise(Errors::MissingClient)
end

def self.write(client)

Returns:
  • (Karafka::Connection::Client) - persisted messages consumer client

Parameters:
  • client (Karafka::Connection::Client) -- messages consumer client of 
def self.write(client)
  Thread.current[PERSISTENCE_SCOPE] = client
end