class Karafka::Persistence::Consumer

def all

Returns:

(Hash) - current thread persistence scope hash with all the consumers

def all
  # @note This does not need to be threadsafe (Hash) as it is always executed in a
  # current thread context
  Thread.current[PERSISTENCE_SCOPE] ||= Hash.new { |hash, key| hash[key] = {} }
end

Instance Methods