class Karafka::Persistence::Client

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

Class Methods