class Karafka::Connection::Listener

def call

Runs prefetch callbacks and executes the main listener fetch loop
def call
  Karafka::Callbacks.before_fetch_loop(
    @consumer_group,
    client
  )
  fetch_loop
end