class Karafka::Connection::Listener

def client

Returns:

(Karafka::Connection::Client) - wrapped kafka consuming client for a given topic

def client
  @client ||= Client.new(@consumer_group)
end

Instance Methods