class Karafka::BaseConsumer

def client

Returns:
  • (Karafka::Connection::Client) - messages consuming client that can be used to 
def client
  Persistence::Client.read
end