lib/karafka/instrumentation/notifications.rb in karafka-2.4.9 vs lib/karafka/instrumentation/notifications.rb in karafka-2.4.10
- old
+ new
@@ -46,9 +46,12 @@
connection.listener.quieting
connection.listener.quiet
connection.listener.stopping
connection.listener.stopped
+ consumer.initialize
+ consumer.initialized
+
consumer.before_schedule_consume
consumer.consume
consumer.consumed
consumer.consuming.pause
consumer.consuming.retry