lib/karafka/instrumentation/notifications.rb in karafka-2.2.13 vs lib/karafka/instrumentation/notifications.rb in karafka-2.2.14

@@ -18,40 +18,42 @@
       #   Karafka system to determine all of the events you can use.
       EVENTS = %w[
         active_job.consume
         active_job.consumed
 
+        app.initializing
         app.initialized
         app.running
         app.quieting
         app.quiet
         app.stopping
         app.stopped
         app.terminated
 
         client.pause
         client.resume
+        client.reset
 
         connection.listener.before_fetch_loop
         connection.listener.fetch_loop
         connection.listener.fetch_loop.received
 
-        connection.client.poll.error
-        connection.client.unsubscribe.error
-
         rebalance.partitions_assign
         rebalance.partitions_assigned
         rebalance.partitions_revoke
         rebalance.partitions_revoked
 
-        consumer.before_enqueue
+        consumer.before_schedule_consume
         consumer.consume
         consumer.consumed
         consumer.consuming.pause
         consumer.consuming.retry
+        consumer.before_schedule_idle
         consumer.idle
+        consumer.before_schedule_revoked
         consumer.revoke
         consumer.revoked
+        consumer.before_schedule_shutdown
         consumer.shutting_down
         consumer.shutdown
 
         dead_letter_queue.dispatched