lib/karafka/instrumentation/notifications.rb in karafka-2.3.4 vs lib/karafka/instrumentation/notifications.rb in karafka-2.4.0.beta1
- old
+ new
@@ -38,10 +38,18 @@
connection.listener.before_fetch_loop
connection.listener.fetch_loop
connection.listener.fetch_loop.received
connection.listener.after_fetch_loop
+ connection.listener.pending
+ connection.listener.starting
+ connection.listener.running
+ connection.listener.quieting
+ connection.listener.quiet
+ connection.listener.stopping
+ connection.listener.stopped
+
consumer.before_schedule_consume
consumer.consume
consumer.consumed
consumer.consuming.pause
consumer.consuming.retry
@@ -63,9 +71,11 @@
dead_letter_queue.dispatched
filtering.throttled
filtering.seek
+
+ oauthbearer.token_refresh
process.notice_signal
rebalance.partitions_assign
rebalance.partitions_assigned